cadonna opened a new pull request, #12600: URL: https://github.com/apache/kafka/pull/12600
In the first attempt to handle revoked tasks in the state updater we removed the revoked tasks from the state updater and added it to the set of pending tasks to close cleanly. This is not correct since a revoked task that is immediately reassigned to the same stream thread would neither be re-added to the state updater nor be created again. Also a revoked active task might be added to more than one bookkeeping set in the tasks registry since it might still be returned from stateUpdater.getTasks() after it was removed from the state updater. The reason is that the removal from the state updater is done asynchronously. This PR solves this issue by introducing a new bookkeeping set in the tasks registry to bookkeep revoked active tasks (actually suspended active tasks). Additionally this PR closes some testing holes around the modified code. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) -- 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
