Hi Levani, I think you found a bug and you are looking at the right place!
I commented on the PR. Best, Bruno On 10/10/23 3:02 PM, Levani Kokhreidze wrote:
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
