Fix cpu spin loop when pending is closed while buf is not empty

IBM · Jun 5, 2024 · 634f4b6 · 634f4b6
1 parent 3fad210
commit 634f4b6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -865,6 +865,9 @@ func (p *asyncProducer) newBrokerProducer(broker *Broker) *brokerProducer {
 			select {
 			case res, ok := <-pending:
 				if !ok {
+					if buf.Length() != 0 {
+						time.Sleep(bp.parent.conf.Producer.Retry.Backoff)
+					}
 					continue
 				}
 				buf.Add(res)