[GitHub] [kafka] guozhangwang commented on a diff in pull request #12638: Register and unregister changelog topics in state updater

guozhangwang commented on code in PR #12638: URL: https://github.com/apache/kafka/pull/12638#discussion_r972283623 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java: ## @@ -209,7 +212,9 @@ void registerStateStores(final List

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12638: Register and unregister changelog topics in state updater

guozhangwang commented on code in PR #12638: URL: https://github.com/apache/kafka/pull/12638#discussion_r971076310 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java: ## @@ -575,8 +584,10 @@ public void close() throws