Hello, We’ve been looking at a https://issues.apache.org/jira/browse/KAFKA-10575 but seems implementation has a bug and user defined `StateRestoreListener#onRestoreSuspended` is not called because DelegatingStateRestoreListener was not updated.
Here’s the PR that fixes it: https://github.com/apache/kafka/pull/14519 I will add the tests, but first wanted to make sure I’m looking at a correct place and if I’m missing something. Issue link: https://issues.apache.org/jira/browse/KAFKA-15571 Best, Levani
