Guozhang Wang created KAFKA-10575:
-------------------------------------
Summary: StateRestoreListener#onRestoreEnd should always be
triggered
Key: KAFKA-10575
URL: https://issues.apache.org/jira/browse/KAFKA-10575
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Guozhang Wang
Today we only trigger `StateRestoreListener#onRestoreEnd` when we complete the
restoration of an active task and transit it to the running state. However the
restoration can also be stopped when the restoring task gets closed (because it
gets migrated to another client, for example). We should also trigger the
callback indicating its progress when the restoration stopped in any scenarios.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
