From 5f40182185486ab17cf13685ee4f177c8a10a7ff Mon Sep 17 00:00:00 2001 From: Felix Geller Date: Sat, 9 Sep 2023 14:09:26 +0200 Subject: [PATCH] gofmt --- produce.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/produce.go b/produce.go index 2e05ebb..496dc3a 100644 --- a/produce.go +++ b/produce.go @@ -349,7 +349,7 @@ func (cmd *produceCmd) deserializeLines(in chan string, out chan message, partit if msg.Value != nil && cmd.partitioner == "hashCodeByValue" { part = hashCodePartition(*msg.Value, partitionCount) msg.Partition = &part - }else { + } else { if msg.Key != nil && cmd.partitioner == "hashCode" { part = hashCodePartition(*msg.Key, partitionCount) } @@ -469,7 +469,6 @@ func (cmd *produceCmd) produceBatch(leaders map[int32]*sarama.Broker, batch []me offsets, err := cmd.readPartitionOffsetResults(resp) if err != nil { - return fmt.Errorf("failed to read producer response err=%s", err) }