[GitHub] [kafka] guozhangwang commented on a diff in pull request #12312: KAFKA-10199: Expose tasks in state updater

guozhangwang commented on code in PR #12312: URL: https://github.com/apache/kafka/pull/12312#discussion_r906222088 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java: ## @@ -86,7 +88,7 @@ public Collection getUpdatingStandbyTasks() {

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12312: KAFKA-10199: Expose tasks in state updater

guozhangwang commented on code in PR #12312: URL: https://github.com/apache/kafka/pull/12312#discussion_r903296637 ## streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java: ## @@ -603,6 +655,178 @@ public void shouldDrainFailedTasksAndEx