Travis Bischel
Travis Bischel
Please add the one comment & squash commits (or at the least, squash commits) -- looks good otherwise, will merge once squashed.
Why not use `Unwrap` to get the inner error, rather than exposing the error?
I haven't forgotten -- I'm primarily waiting until this weekend or next (or next) to set aside time to implement the three new KIPs that were released in Kafka 3.8....
Bit of a delay on my side... releasing this evening.
Was the batch produced at the offset you're consuming from very large? Kafka does not return individual records, only batches.
Connections can die regularly -- e.g., internet traffic weather, temporary internet outages. IMO warn is reserved for things that shouldn't happen but we can recover, but you should really know...
Would it be preferable to shield it from the reaper, or would a function that ensures a producer connection to a specific broker is open (or all brokers with node...
Have you tried adjusting ConnIdleTimeout? Is that an option?
PTAL at the function introduced in this PR: https://github.com/twmb/franz-go/pull/839 I don't think I'm going to squeeze this into the next release (tonight), so this may wait a month unfortunately, but...
Three proposals for potential alternatives: 1. Keep the existing API, but change the logic to actually send an ApiVersions request on the opened connection. This will force it to be...