Fix bug -- we don't want to remove true value for clientEpochBump

apache · Dec 18, 2024 · cb99d6c · cb99d6c
1 parent b85f758
commit cb99d6c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
@@ -460,7 +460,8 @@ public synchronized void maybeUpdateTransactionV2Enabled(boolean onInitiatializa
         Short transactionVersion = info.finalizedFeatures.get("transaction.version");
         boolean wasTransactionV2Enabled = isTransactionV2Enabled;
         isTransactionV2Enabled = transactionVersion != null && transactionVersion >= 2;
-        clientSideEpochBumpRequired = !onInitiatialization && !wasTransactionV2Enabled && isTransactionV2Enabled;
+        if (!onInitiatialization && !wasTransactionV2Enabled && isTransactionV2Enabled)
+            clientSideEpochBumpRequired = true;
     }
 
     public boolean isTransactionV2Enabled() {