Description
Part of KIP-869: https://cwiki.apache.org/confluence/display/KAFKA/KIP-869%3A+Improve+Streams+State+Restoration+Visibility
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.
Attachments
Issue Links
- Is contained by
-
KAFKA-10199 Separate state restoration into separate threads
-
- Reopened
-
- is fixed by
-
KAFKA-15571 StateRestoreListener#onRestoreSuspended is never called because wrapper DelegatingStateRestoreListener doesn't implement onRestoreSuspended
-
- Resolved
-
- links to