From b398ef556473dcfd42eeeb77d2f6afb5d75a7103 Mon Sep 17 00:00:00 2001 From: Vincent Potucek Date: Thu, 18 Dec 2025 12:05:42 +0100 Subject: [PATCH] KAFKA-19925: Fix transaction timeout handling during broker upgrades #21161 #KAFKA-20000 Signed-off-by: Vincent Potucek --- .../kafka/clients/producer/internals/TransactionManager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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 index 969085809e656..e2ebcd5212d9e 100644 --- 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 @@ -1572,13 +1572,12 @@ public void handleResponse(AbstractResponse response) { TopicPartition topicPartition = topicPartitionErrorEntry.getKey(); Errors error = topicPartitionErrorEntry.getValue(); - if (error == Errors.NONE) { - continue; - } else if (error == Errors.COORDINATOR_NOT_AVAILABLE || error == Errors.NOT_COORDINATOR) { + if (error == Errors.COORDINATOR_NOT_AVAILABLE || error == Errors.NOT_COORDINATOR) { lookupCoordinator(FindCoordinatorRequest.CoordinatorType.TRANSACTION, transactionalId); reenqueue(); return; } else if (error == Errors.CONCURRENT_TRANSACTIONS) { + retryBackoffMs = ADD_PARTITIONS_RETRY_BACKOFF_MS; maybeOverrideRetryBackoffMs(); reenqueue(); return;