From 9bd82191aae82f77e2ba7084597c54e0d0189021 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=2E=20Mert=20Y=C4=B1ld=C4=B1ran?= Date: Mon, 31 Jan 2022 14:46:22 +0300 Subject: [PATCH] Fix the source-destination flip in Kafka (#729) --- tap/extensions/kafka/response.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tap/extensions/kafka/response.go b/tap/extensions/kafka/response.go index 46233eed9..a35790586 100644 --- 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, }