consumer/async.go
func (c *Consumer) SetMaxRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.maxRetryDelay, int64(d))
}
func (c *Consumer) SetMaxRetryDelay(d time.Duration) {
	atomic.StoreInt64(&c.maxRetryDelay, int64(d))
}
func ( c * Consumer ) SetMaxRetryDelay ( d time . Duration ) { atomic . StoreInt64 ( & c . maxRetryDelay , int64 ( d ) ) }
// SetMaxRetryDelay sets the maximum duration that automatically reconnecting
// methods on c (e.g. Firehose, Stream, TailingLogs) will sleep for after
// receiving many successive errors from the traffic controller.
//
// Defaults to DefaultMaxRetryDelay.
SetMaxRetryDelay sets the maximum duration that automatically reconnecting methods on c ( e . g . Firehose Stream TailingLogs ) will sleep for after receiving many successive errors from the traffic controller . Defaults to DefaultMaxRetryDelay .