[KAFKA-17898] Seperate Epoch Bump Scenarios and Error Handling in TV2

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Assignee: Ritika Reddy
• Reporter: Ritika Reddy
• Created: 29/Oct/24 21:47
• Updated: 25/Nov/24 22:29
• Resolved: 25/Nov/24 22:29

Description

With 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 used to handle epoch bumping.

Transactional Producers

•  No Epoch Bump Allowed
  • coordinatorSupportsBumpingEpoch = false when initPIDVersion <3 or null

• Client Triggered Epoch Bump Allowed
  • coordinatorSupportsBumpingEpoch = true when initPIDVersion >= 3
  • TransactionVersion2Enabled = false when endTxnVersion < 5

• Only Server Triggered Epoch Bump Allowed
  • Transaction Version 2 = 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.

Issue Links

• links to: GitHub Pull Request #17849