Method backoff

async_producer.go:806–817

(retries int)

}

func (p *asyncProducer) backoff(retries int) {
	var backoff time.Duration
	if p.conf.Producer.Retry.BackoffFunc != nil {
		maxRetries := p.conf.Producer.Retry.Max
		backoff = p.conf.Producer.Retry.BackoffFunc(retries, maxRetries)
	} else {
		backoff = p.conf.Producer.Retry.Backoff
	}
	if backoff > 0 {
		time.Sleep(backoff)
	}
}

func (pp *partitionProducer) updateLeaderIfBrokerProducerIsNil(msg *ProducerMessage) error {
	if pp.brokerProducer == nil {