kafka-go icon indicating copy to clipboard operation
kafka-go copied to clipboard

WriteMessages can force metadata updates when occur NotLeaderForPartition error

Open zydovech opened this issue 1 year ago • 1 comments

WriteMessages will retry , when occur NotLeaderForPartition error, this mean the client's metadata are likely out of date.

Is it possible to force trigger metadata updates? Instead of relying only on metadataTTL for refresh

zydovech avatar Nov 03 '23 10:11 zydovech

@zydovech this seems like a reasonable change but may be quite complex. Feel free to submit a PR with the fix if you have the time. If not a workaround may be to lower your metadata TTL

petedannemann avatar Jan 05 '24 18:01 petedannemann