feat: change kafka sink default balancer (#2946)

Signed-off-by: Song Gao <[email protected]>
lf-edge · Jun 27, 2024 · 72df28d · 72df28d
1 parent efacebe
commit 72df28d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/extensions/sinks/kafka/ext/kafka.go b/extensions/sinks/kafka/ext/kafka.go
@@ -114,9 +114,10 @@ func (m *kafkaSink) buildKafkaWriter() error {
 	}
 	brokers := strings.Split(m.c.Brokers, ",")
 	w := &kafkago.Writer{
-		Addr:                   kafkago.TCP(brokers...),
-		Topic:                  m.c.Topic,
-		Balancer:               &kafkago.LeastBytes{},
+		Addr:  kafkago.TCP(brokers...),
+		Topic: m.c.Topic,
+		// kafka java-client default balancer
+		Balancer:               &kafkago.Murmur2Balancer{},
 		Async:                  false,
 		AllowAutoTopicCreation: true,
 		MaxAttempts:            m.kc.MaxAttempts,