[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10575:
------------------------------------
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.
was: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.
> 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
> Assignee: Guozhang Wang
> Priority: Major
> Fix For: 3.5.0
>
>
> 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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
