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