[GitHub] [kafka] guozhangwang commented on a diff in pull request #12659: KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater

guozhangwang commented on code in PR #12659: URL: https://github.com/apache/kafka/pull/12659#discussion_r980338228 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java: ## @@ -170,6 +174,27 @@ public int hashCode() { */ Set getTasks(

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12659: KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater

guozhangwang commented on code in PR #12659: URL: https://github.com/apache/kafka/pull/12659#discussion_r980337970 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java: ## @@ -500,23 +500,29 @@ public void remove(final TaskId taskId) {

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12659: KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater

guozhangwang commented on code in PR #12659: URL: https://github.com/apache/kafka/pull/12659#discussion_r978255351 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java: ## @@ -170,6 +174,27 @@ public int hashCode() { */ Set getTasks(

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12659: KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater

guozhangwang commented on code in PR #12659: URL: https://github.com/apache/kafka/pull/12659#discussion_r978255189 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java: ## @@ -500,23 +500,29 @@ public void remove(final TaskId taskId) {