bug: fix kafka transport

* set default partitioner to roundrobin
netsampler · Dec 3, 2023 · af010d8 · af010d8
1 parent a1750f5
commit af010d8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/transport/kafka/kafka.go b/transport/kafka/kafka.go
@@ -120,6 +120,7 @@ func (d *KafkaDriver) Init() error {
 	kafkaConfig.Producer.MaxMessageBytes = d.kafkaMaxMsgBytes
 	kafkaConfig.Producer.Flush.Bytes = d.kafkaFlushBytes
 	kafkaConfig.Producer.Flush.Frequency = d.kafkaFlushFrequency
+	kafkaConfig.Producer.Partitioner = sarama.NewRoundRobinPartitioner
 
 	if d.kafkaCompressionCodec != "" {
 		/*