Travis Bischel
Travis Bischel
This is failing before a fetch is even issued. Currently, KeepRetryableFetchErrors only applies to errors that are returned from an actual FetchResponse (not MetadataResponse). I don't see a way in...
I think that'd work, and I also wonder if franz-go should bubble errors from metadata updates as well (i.e. inject a fake fetch)
client.Ping will help that use case, yes
Metadata topic or partition failures now inject fake fetches; retryable topic or partition errors now inject fake fetches if KeepRetryableFetchErrors is used. This is in https://github.com/twmb/franz-go/commit/a2340ebb21a42fbd01d695aa2df109854050670e
I did not go the route of adding a new callback -- I think injecting a fake fetch is better here.
What's your code that is logging that line? Do you have an OnRevoked or OnLost?
I don't have the time right now to really write the code to recreate the scenario right now. What you have looks correct. Is it possible to create a small...
I've ran it a few times and I'm not seeing it.
Closing for now, please let me know if there's something further to go on. Apologies I haven't been able to make progress but, you're describing something I haven't seen nor...
I wonder if you're running into what #705 ran into; if so, I have a fix in the next release.