From efb953c94feae9081f2591e3f907ec70385139d4 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Sun, 3 Nov 2024 16:10:05 -0800
Subject: [PATCH] Clean

---
 lib/kafkalib/writer.go | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/lib/kafkalib/writer.go b/lib/kafkalib/writer.go
index 85a8bb9b..a4f20679 100644
--- a/lib/kafkalib/writer.go
+++ b/lib/kafkalib/writer.go
@@ -121,10 +121,7 @@ func (b *BatchWriter) write(ctx context.Context, messages []KafkaMessage, sample
 	}
 
 	return batch.BySize[KafkaMessage](messages, int(b.writer.BatchBytes), encoder, func(chunk [][]byte) error {
-		tags := map[string]string{
-			"what": "error",
-		}
-
+		tags := map[string]string{"what": "error"}
 		defer func() {
 			if b.statsD != nil {
 				b.statsD.Count("kafka.publish", int64(len(chunk)), tags)