Clean

artie-labs · Nov 4, 2024 · efb953c · efb953c
1 parent 16121aa
commit efb953c
Showing 1 changed file with 1 addition and 4 deletions.
diff --git 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)