jolshan commented on code in PR #13876: URL: https://github.com/apache/kafka/pull/13876#discussion_r1235917215
########## clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java: ########## @@ -1013,16 +1013,8 @@ private void maybeFailWithError() { if (!hasError()) { return; } - // for ProducerFencedException, do not wrap it as a KafkaException - // but create a new instance without the call trace since it was not thrown because of the current call - if (lastError instanceof ProducerFencedException) { - throw new ProducerFencedException("Producer with transactionalId '" + transactionalId - + "' and " + producerIdAndEpoch + " has been fenced by another producer " + - "with the same transactionalId"); - } - if (lastError instanceof InvalidProducerEpochException) { Review Comment: I saw we had some tests that verified producer fenced, but do we not have any for invalid producer epoch here? -- 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