From 3f3b01b8075620b5900a112b30e3b6c95bd25df0 Mon Sep 17 00:00:00 2001 From: mhmtszr Date: Fri, 6 Oct 2023 12:00:30 +0300 Subject: [PATCH] Fix fatal error message format --- kafka/producer/producer_batch.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/producer/producer_batch.go b/kafka/producer/producer_batch.go index 58a4aa9..d664cc9 100644 --- a/kafka/producer/producer_batch.go +++ b/kafka/producer/producer_batch.go @@ -110,7 +110,7 @@ func (b *Batch) FlushMessages() { err := b.Writer.WriteMessages(context.Background(), b.messages...) if err != nil { if isFatalError(err) { - panic(fmt.Errorf("permanent error on Kafka side %e", err)) + panic(fmt.Errorf("permanent error on Kafka side %v", err)) } logger.Log.Error("batch producer flush error %v", err) return