more logging

IBM · Jul 20, 2024 · b73a5f2 · b73a5f2
1 parent 1125d60
commit b73a5f2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/async_producer.go b/async_producer.go
@@ -252,12 +252,15 @@ type ProducerErrors []*ProducerError
 func (pe ProducerErrors) Error() string {
 	if len(pe) > 0 {
 		return fmt.Sprintf(
-			"kafka: Failed to deliver %d messages, sample error: %v after %d retries on topic: %s and partition: %d",
+			"kafka: Failed to deliver %d messages, sample error: %v after %d retries on topic: %s and partition: %d with producerEpoch: %d and sequence: %d(%v)",
 			len(pe),
 			pe[0].Err,
 			pe[0].Msg.retries,
 			pe[0].Msg.Topic,
 			pe[0].Msg.Partition,
+			pe[0].Msg.producerEpoch,
+			pe[0].Msg.sequenceNumber,
+			pe[0].Msg.hasSequence,
 		)
 	}
 	return fmt.Sprintf("kafka: Failed to deliver %d messages.", len(pe))