Skip to content

Commit

Permalink
Fix fatal error message format
Browse files Browse the repository at this point in the history
  • Loading branch information
mhmtszr committed Oct 6, 2023
1 parent f7db3af commit 3f3b01b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion kafka/producer/producer_batch.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 3f3b01b

Please sign in to comment.