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))
}
// 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.