cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r966978149
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,95 @@ private void classifyTasksWithoutStateUpdater(final
Map
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r966987932
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,95 @@ private void classifyTasksWithoutStateUpdater(final
Map
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r966991995
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -817,14 +867,17 @@ private boolean handleRestoredTasksFromStateUpdater(fina
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r968207039
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -960,7 +1011,7 @@ private void removeRevokedTasksFromStateUpdater(final
Se
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r968378813
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -52,11 +53,8 @@ class Tasks implements TasksRegistry {
// we receive a new a
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r968441157
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,96 @@ private void classifyTasksWithoutStateUpdater(final
Map
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r968443807
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -960,7 +1011,7 @@ private void removeRevokedTasksFromStateUpdater(final
Se
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970637424
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -103,42 +101,75 @@ public void addPendingStandbyTasksToCreate(final
Map
@
cadonna commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970668525
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -421,73 +421,95 @@ private void classifyTasksWithoutStateUpdater(final
Map