rreddy-22 commented on code in PR #17849:
URL: https://github.com/apache/kafka/pull/17849#discussion_r1857015099
##########
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##########
@@ -760,8 +760,8 @@ synchronized void maybeResolveSequences() {
// For the transactional producer, we bump the epoch
if possible, otherwise we transition to a fatal error
String unackedMessagesErr = "The client hasn't
received acknowledgment for some previously " +
"sent messages and can no longer retry them. ";
- if (canBumpEpoch()) {
- epochBumpRequired = true;
+ if (canTriggerEpochBump()) {
Review Comment:
Thanks for the catch! Wrote a test case and a fix for the same!
--
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]
