From 062fe41934c5d653ef98f2a55c86ea8ffe454f8f Mon Sep 17 00:00:00 2001
From: slaventius <slaventius@mail.ru>
Date: Tue, 14 Mar 2023 11:04:25 +0300
Subject: [PATCH] *

---
 internal/transport/kafka/writer.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/internal/transport/kafka/writer.go b/internal/transport/kafka/writer.go
index 3d6dcb1..6954f0c 100644
--- 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...),