dongnuo123 opened a new pull request, #17007: URL: https://github.com/apache/kafka/pull/17007
https://issues.apache.org/jira/browse/KAFKA-17317 This patch makes the online downgrade trigger asynchronous by scheduling a timer to validate and execute downgrade in the appendFuture of the coordinator result. This also fixes the bug discovered in the system test, where the group can't be downgraded when the last static member using the consumer protocol is replaced by a classic member with the same instance id. ### 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
