(kafka) branch 4.0 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.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


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

commit 3c62b6b87442ab621ad729af58f6f08a5468793c
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 970461cfecf..bcdab50152c 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
@@ -1856,9 +1856,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);
         }
     }