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
