franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.6+. Producing, consuming, transacting, administrating, etc.
I just realised that the kgo.RequestTimeoutOverhead() is the default timeout for most of the requests. I didn't understand it just reading the doc, as I thought it was always an overhead. I'm proposing a small rephrasing of the doc: does it make sense to you?
I just realised that the
kgo.RequestTimeoutOverhead()
is the default timeout for most of the requests. I didn't understand it just reading the doc, as I thought it was always an overhead. I'm proposing a small rephrasing of the doc: does it make sense to you?