yangfeng123456 opened a new pull request, #21359:
URL: https://github.com/apache/kafka/pull/21359
What’s the problem:
- When commitOffsetsAsync fails, the client callback sometimes doesn’t get
called.
This can leave clients hanging, not knowing their commit actually failed.
What’s the fix:
- In doCommitOffsetsAsync.onFailure, call the provided OffsetCommitCallback
immediately if it’s not null.
- This ensures clients are always notified about commit failures, fixing
KAFKA-10489.
Things to note:
- Rare edge case: if a rebalance happens while a commit is in flight, the
callback might be triggered twice.
- Overall, this is safer than the current behavior where clients might never
hear about the failure.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
