code: func (c *Consumer) SetMaxRetryCount(count int) {
  	atomic.StoreInt64(&c.maxRetryCount, int64(count))
  }
docs: // SetMaxRetryCount sets the maximum number of reconnnection attemps that
  // methods on c (e.g. Firehose, Stream, TailingLogs) will make before failing.
  //
  // Defaults to DefaultMaxRetryCount.