k-raina opened a new pull request, #19204:
URL: https://github.com/apache/kafka/pull/19204
Current Behavior:
- When a batch fails with a fatal error (e.g., ProducerFencedException), the
TM transitions to FATAL state
- However, subsequent batches that fail can still trigger state transitions
through code path `Sender.failBatch -> TM.handleFailedBatch >
TM.maybeTransitionToErrorState`
- This means that even after entering FATAL state, other batches could
potentially transition the TM to ABORTABLE state
Example Scenario:
```
Batch 1 fails with ProducerFencedException
↓
TM transitions to FATAL state
↓
Batch 2 fails with UnknownProducerIdException
↓
TM incorrectly transitions to ABORTABLE state (this is the bug)
```
--
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]
