consumer/async.go
func (c *Consumer) SetMinRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.minRetryDelay, int64(d))
}
func (c *Consumer) SetMinRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.minRetryDelay, int64(d))
}
// SetMinRetryDelay sets the duration that automatically reconnecting methods
// on c (e.g. Firehose, Stream, TailingLogs) will sleep for after receiving
// an error from the traffic controller.
//
// Successive errors will double the sleep time, up to c's max retry delay,
// set by c.SetMaxRetryDelay.
//
// Defaults to DefaultMinRetryDelay.