From c5dc0e9a840667ead2de7e83fbff55a372918238 Mon Sep 17 00:00:00 2001 From: Nathan Villaescusa Date: Sat, 30 Mar 2024 14:28:12 -0700 Subject: [PATCH] Remove s --- lib/kafkalib/writer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/kafkalib/writer.go b/lib/kafkalib/writer.go index e3b821d8..d29223f9 100644 --- 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) }