dont clear message before logging

IBM · Jul 20, 2024 · 0222838 · 0222838
1 parent b73a5f2
commit 0222838
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -1436,7 +1436,6 @@ func (p *asyncProducer) returnError(msg *ProducerMessage, err error) {
 		p.bumpIdempotentProducerEpoch()
 	}
 
-	msg.clear()
 	pErr := &ProducerError{Msg: msg, Err: err}
 	if p.conf.Producer.Return.Errors {
 		p.errors <- pErr
@@ -1455,7 +1454,6 @@ func (p *asyncProducer) returnErrors(batch []*ProducerMessage, err error) {
 func (p *asyncProducer) returnSuccesses(batch []*ProducerMessage) {
 	for _, msg := range batch {
 		if p.conf.Producer.Return.Successes {
-			msg.clear()
 			p.successes <- msg
 		}
 		p.inFlight.Done()