*

2 years ago · 062fe41934
parent ed68c779cf
commit 062fe41934
1 changed files with 3 additions and 2 deletions
--- a/internal/transport/kafka/writer.go
+++ b/internal/transport/kafka/writer.go
@ -95,8 +95,9 @@ func NewWriter(ctx context.Context, logger *logger.Logger, topic string, address
 	s := &KafkaWriter{
 		ctx: ctx,
 		writer: &kafka.Writer{
-			Topic:           topic,
-			Balancer:        &kafka.LeastBytes{},
+			Topic:    topic,
+			Balancer: &kafka.LeastBytes{},
+			// Balancer:        &kafka.Murmur2Balancer{},
 			WriteBackoffMax: time.Millisecond * 100,
 			BatchTimeout:    time.Millisecond * 100,
 			Addr:            kafka.TCP(address...),