rreddy-22 opened a new pull request, #17849: URL: https://github.com/apache/kafka/pull/17849
With [KAFKA-14562](https://issues.apache.org/jira/browse/KAFKA-14562), we implemented epoch bump on both the client and the server. Mentioned below are the different epoch bump scenarios we have on hand after enabled tv2 **Non-Transactional Producers** • Epoch bumping is always allowed. • Different code paths are used to handle epoch bumping. **Transactional Producers** 1. No Epoch Bump Allowed • coordinatorSupportsBumpingEpoch = false when initPIDVersion < 3 or initPIDVersion = null. 2. Client-Triggered Epoch Bump Allowed • coordinatorSupportsBumpingEpoch = true when initPIDVersion >= 3. • TransactionVersion2Enabled = false when endTxnVersion < 5. 3. Only Server-Triggered Epoch Bump Allowed • TransactionVersion2Enabled = true and endTxnVersion >= 5. We want to refine the code and make it more structured to correctly handle epoch bumping in the above mentioned cases. -- 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]
