[GitHub] [kafka] guozhangwang commented on a diff in pull request #12427: KAFKA-10199: Add tasks to state updater when they are created

guozhangwang commented on code in PR #12427: URL: https://github.com/apache/kafka/pull/12427#discussion_r929113602 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java: ## @@ -136,10 +139,14 @@ private void createActiveTasks(final Map> activeTask

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12427: KAFKA-10199: Add tasks to state updater when they are created

guozhangwang commented on code in PR #12427: URL: https://github.com/apache/kafka/pull/12427#discussion_r927038139 ## streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java: ## @@ -273,4 +281,70 @@ public static boolean isCheckSupplierCall() { return