kafka
kafka copied to clipboard
KAFKA-9910: Implement new transaction timed out error
The producer recovers by internally sending InitProducerId with the current epoch when received TRANSACTION_TIMED_OUT error.
Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
@abbccdda @hachikuji Comments have been addressed, could you continue to review the pr.
retest this please
This feature would be very useful and seems almost ready. Any help wanted to complete the task?