You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "highluck (Jira)" <ji...@apache.org> on 2020/12/07 16:17:00 UTC

[jira] [Commented] (KAFKA-10575) StateRestoreListener#onRestoreEnd should always be triggered

    [ https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245318#comment-17245318 ] 

highluck commented on KAFKA-10575:
----------------------------------

[~Yohan123] 
Are you working on this task?

> 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
>            Priority: Major
>
> 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)