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

[mjsax]

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

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


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

commit 4b5387cbc2c0e041fb756fd09d027e2a816c2a34
Author: Matthias J. Sax <matth...@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 <lbruts...@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 fab9db663b5..7243fb886e3 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
@@ -1898,9 +1898,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);
         }
     }