(kafka) branch 4.1 updated: KAFKA-20002: Reset-by-duration should not hand back task to state-updater (#21167)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 4.1
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/4.1 by this push:
     new 01b8fca8034 KAFKA-20002: Reset-by-duration should not hand back task to state-updater (#21167)
01b8fca8034 is described below

commit 01b8fca8034b6cc165d32ad724e80535e96c0b73
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Fri Dec 19 16:15:58 2025 -0800

    KAFKA-20002: Reset-by-duration should not hand back task to state-updater (#21167)
    
    This bug was introduced via KAFKA-18015.
    
    Reviewers: Lucas Brutschy <lb...@confluent.io>, Vincent Potuček
     (@Pankraz76)
---
 .../org/apache/kafka/streams/processor/internals/TaskManager.java     | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
index 13efca5b200..e2cd723ee33 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
@@ -1884,9 +1884,7 @@ public class TaskManager {
         final long nowMs
     ) {
         for (final TopicPartition partition : partitions) {
-            final Task task = getActiveTask(partition);
-            task.maybeInitTaskTimeoutOrThrow(nowMs, timeoutException);
-            stateUpdater.add(task);
+            getActiveTask(partition).maybeInitTaskTimeoutOrThrow(nowMs, timeoutException);
         }
     }