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-unsubscr...@kafka.apache.org

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

Reply via email to