Added comment about why we are sorting IP address for generating kafk…

…a key
netobserv · Apr 6, 2023 · b6ca6ad · b6ca6ad
1 parent eb3f171
commit b6ca6ad
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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[:]...)