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 <[email protected]>
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 <[email protected]>, 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);
}
}