jolshan commented on code in PR #13811:
URL: https://github.com/apache/kafka/pull/13811#discussion_r1220507827
##########
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##########
@@ -1376,7 +1376,7 @@ public void handleResponse(AbstractResponse response) {
fatalError(error.exception());
return;
} else if (error == Errors.INVALID_TXN_STATE) {
- fatalError(new KafkaException(error.exception()));
Review Comment:
As mentioned, in the other instance, this probably won't be returned to the
client, but in the case that it was -- could there be a client that expects the
wrapped error? At this point, it's probably not an issue, but just curious the
implication.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
