Merge pull request #2208 from k-wall/retry-batch-leak

fix: prevent AsyncProducer retryBatch from leaking
IBM · Apr 13, 2022 · 602d831 · 602d831
2 parents 2c04192 + c34e274
commit 602d831
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -1064,6 +1064,7 @@ func (p *asyncProducer) retryBatch(topic string, partition int32, pSet *partitio
 	}
 	bp := p.getBrokerProducer(leader)
 	bp.output <- produceSet
+	p.unrefBrokerProducer(leader, bp)
 }
 
 func (bp *brokerProducer) handleError(sent *produceSet, err error) {