ijuma commented on code in PR #15315: URL: https://github.com/apache/kafka/pull/15315#discussion_r1478629131
########## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java: ########## @@ -343,6 +343,19 @@ void abortTransaction() { // something else (e.g. task corrupted) we can still ignore the exception here // since transaction already got aborted by brokers/transactional-coordinator if this happens log.debug("Encountered {} while aborting the transaction; this is expected and hence swallowed", error.getMessage()); + } catch (final IllegalStateException maybeSwallow) { + // cf https://issues.apache.org/jira/browse/KAFKA-16221 + // this is a hotfix for 3.7 release to just detect this edge case and swallow the exception + // a proper fix would skip calling `abortTransaction` to begin with + final String errorMessage = maybeSwallow.getMessage(); + if (errorMessage == null || !errorMessage.endsWith("Invalid transition attempted from state FATAL_ERROR to state ABORTABLE_ERROR")) { Review Comment: I've seen temporary fixes last for a long time and hence why I asked whether we are actively working on the proper fix ("discussions" doesn't feel strong enough to me). -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org