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))
}
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.
SetMaxRetryCount sets the maximum number of reconnnection attemps that methods on c ( e . g . Firehose Stream TailingLogs ) will make before failing . Defaults to DefaultMaxRetryCount .