Fix the source-destination flip in Kafka (#729 )

2026-03-02 02:22:17 +00:00 · 2022-01-31 14:46:22 +03:00
1 changed files with 4 additions and 4 deletions
--- a/tap/extensions/kafka/response.go
+++ b/tap/extensions/kafka/response.go
@@ -251,10 +251,10 @@ func ReadResponse(r io.Reader, tcpID *api.TcpID, superTimer *api.SuperTimer, emi
 	}

 	connectionInfo := &api.ConnectionInfo{
-		ClientIP:   tcpID.SrcIP,
-		ClientPort: tcpID.SrcPort,
-		ServerIP:   tcpID.DstIP,
-		ServerPort: tcpID.DstPort,
+		ClientIP:   tcpID.DstIP,
+		ClientPort: tcpID.DstPort,
+		ServerIP:   tcpID.SrcIP,
+		ServerPort: tcpID.SrcPort,
 		IsOutgoing: true,
 	}