[GitHub] [kafka] guozhangwang commented on a diff in pull request #12654: KAFKA-10575: Add onRestoreSuspsnded to StateRestoreListener

guozhangwang commented on code in PR #12654: URL: https://github.com/apache/kafka/pull/12654#discussion_r1092384524 ## streams/src/test/java/org/apache/kafka/streams/processor/internals/StoreChangelogReaderTest.java: ## @@ -197,6 +198,49 @@ public void

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12654: KAFKA-10575: Add onRestoreSuspsnded to StateRestoreListener

guozhangwang commented on code in PR #12654: URL: https://github.com/apache/kafka/pull/12654#discussion_r1092383808 ## streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java: ## @@ -37,6 +37,9 @@ * These two interfaces serve different restoration