diff --git a/async_producer.go b/async_producer.go
index f629a6a2e..8c0dae8f1 100644
--- 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)