From b6ca6ad601ddcdbcc3671c85cd9bf5f18def1279 Mon Sep 17 00:00:00 2001 From: Olivier Cazade Date: Thu, 6 Apr 2023 12:22:51 +0200 Subject: [PATCH] Added comment about why we are sorting IP address for generating kafka key --- pkg/exporter/kafka_proto.go | 1 + 1 file changed, 1 insertion(+) diff --git a/pkg/exporter/kafka_proto.go b/pkg/exporter/kafka_proto.go index 31c89d9e9..61338e8d7 100644 --- a/pkg/exporter/kafka_proto.go +++ b/pkg/exporter/kafka_proto.go @@ -29,6 +29,7 @@ func (kp *KafkaProto) ExportFlows(input <-chan []*flow.Record) { } func getFlowKey(record *flow.Record) []byte { + // We are sorting IP address so flows from on ip to a second IP get the same key whatever the direction is for k := range record.Id.SrcIp { if record.Id.SrcIp[k] < record.Id.DstIp[k] { return append(record.Id.SrcIp[:], record.Id.DstIp[:]...)