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

Posted to jira@kafka.apache.org by GitBox <gi...@apache.org> on 2022/09/08 18:08:13 UTC

[GitHub] [kafka] guozhangwang commented on pull request #12600: KAFKA-10199: Remove and suspend tasks in the state updater on revocation

guozhangwang commented on PR #12600:
URL: https://github.com/apache/kafka/pull/12600#issuecomment-1241058075

   > I am not sure I can follow. Are you proposing to not recycle or resume revoked active tasks?
   
   What I'm proposing is that, for restoring active tasks, we can actually ignore them at the `handleRevocation` phase, but only handle them at the `handleAssignment` phase, where we would then know if the task is still owned, or should be closed, or should be recycled. At that time we add them to the corresponding pending tasks, and then call `stateUpdater.remove`.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org