[GitHub] [kafka] hachikuji commented on a diff in pull request #14088: MINOR: Adjust Invalid Record Exception for Invalid Txn State as mentioned in KIP-890

hachikuji commented on code in PR #14088: URL: https://github.com/apache/kafka/pull/14088#discussion_r1275544007 ## clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java: ## @@ -3107,6 +3099,45 @@ public void

[GitHub] [kafka] hachikuji commented on a diff in pull request #14088: MINOR: Adjust Invalid Record Exception for Invalid Txn State as mentioned in KIP-890

hachikuji commented on code in PR #14088: URL: https://github.com/apache/kafka/pull/14088#discussion_r1272868243 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -732,8 +732,7 @@ class ReplicaManager(val config: KafkaConfig, debug("Produce to local log