urbandan commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r923486565
##########
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##########
@@ -168,6 +171,8 @@ private boolean isTransitionValid(State source, State
target) {
return source == IN_TRANSACTION || source ==
ABORTABLE_ERROR;
case ABORTABLE_ERROR:
return source == IN_TRANSACTION || source ==
COMMITTING_TRANSACTION || source == ABORTABLE_ERROR;
+ case FATAL_BUMPABLE_ERROR:
+ return source != FATAL_ERROR;
Review Comment:
Yes, good catch, cleared that one up
--
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]
