[GitHub] [kafka] ableegoldman commented on a diff in pull request #14326: KAFKA-15429: reset transactionInFlight on StreamsProducer close

ableegoldman commented on code in PR #14326: URL: https://github.com/apache/kafka/pull/14326#discussion_r1313721147 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java: ## @@ -371,6 +371,7 @@ void flush() { void close() { pr

[GitHub] [kafka] ableegoldman commented on a diff in pull request #14326: KAFKA-15429: reset transactionInFlight on StreamsProducer close

ableegoldman commented on code in PR #14326: URL: https://github.com/apache/kafka/pull/14326#discussion_r1313720481 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java: ## @@ -371,6 +371,7 @@ void flush() { void close() { pr