pnagy-cldr commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r923345335
##########
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:
It might make sense to have more fine tuned restriction when we can get into
FATAL_BUMPABLE_ERROR. For example we might not want to get there from
UNINITIALIZED
--
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]
