code: func (c *Consumer) SetMaxRetryDelay(d time.Duration) {
  	atomic.StoreInt64(&c.maxRetryDelay, int64(d))
  }
docs: // 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.