Remove s

artie-labs · Mar 30, 2024 · c5dc0e9 · c5dc0e9
1 parent 87e9eed
commit c5dc0e9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafkalib/writer.go b/lib/kafkalib/writer.go
@@ -92,7 +92,7 @@ func (b *BatchWriter) WriteRawMessages(ctx context.Context, rawMsgs []lib.RawMes
 	for _, rawMsg := range rawMsgs {
 		kafkaMsg, err := newMessage(b.cfg.TopicPrefix, rawMsg)
 		if err != nil {
-			return fmt.Errorf("failed to encode kafka messages: %w", err)
+			return fmt.Errorf("failed to encode kafka message: %w", err)
 		}
 		msgs = append(msgs, kafkaMsg)
 	}