Fix kafka writer configuration causing kafka to ignore key for (#195)

partition distribution
netobserv · Oct 2, 2023 · d744773 · d744773
1 parent eafd494
commit d744773
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/agent/agent.go b/pkg/agent/agent.go
@@ -295,7 +295,7 @@ func buildKafkaExporter(cfg *Config) (node.TerminalFunc[[]*flow.Record], error)
 			Async:        cfg.KafkaAsync,
 			Compression:  compression,
 			Transport:    &transport,
-			Balancer:     &kafkago.RoundRobin{},
+			Balancer:     &kafkago.Hash{},
 		},
 	}).ExportFlows, nil
 }