[GitHub] [kafka] abbccdda commented on a change in pull request #8549: KAFKA-9911: Add new PRODUCER_FENCED error code

abbccdda commented on a change in pull request #8549: URL: https://github.com/apache/kafka/pull/8549#discussion_r468694089 ## File path: core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala ## @@ -539,7 +539,7 @@ class TransactionCoordinator(brokerId:

[GitHub] [kafka] abbccdda commented on a change in pull request #8549: KAFKA-9911: Add new PRODUCER_FENCED error code

abbccdda commented on a change in pull request #8549: URL: https://github.com/apache/kafka/pull/8549#discussion_r468693036 ## File path: clients/src/main/java/org/apache/kafka/common/internals/InvalidProducerEpochException.java ## @@ -0,0 +1,33 @@ +/* + * Licensed to the Apach

[GitHub] [kafka] abbccdda commented on a change in pull request #8549: KAFKA-9911: Add new PRODUCER_FENCED error code

abbccdda commented on a change in pull request #8549: URL: https://github.com/apache/kafka/pull/8549#discussion_r430137301 ## File path: clients/src/main/java/org/apache/kafka/common/errors/InvalidProducerEpochException.java ## @@ -0,0 +1,31 @@ +/* + * Licensed to the Apache S

[GitHub] [kafka] abbccdda commented on a change in pull request #8549: KAFKA-9911: Add new PRODUCER_FENCED error code

abbccdda commented on a change in pull request #8549: URL: https://github.com/apache/kafka/pull/8549#discussion_r416057712 ## File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala ## @@ -297,46 +298,271 @@ class KafkaApisTest { val topic = "topic" setup