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