dongnuo123 opened a new pull request, #17286: URL: https://github.com/apache/kafka/pull/17286
https://issues.apache.org/jira/browse/KAFKA-17317 This patch makes the online downgrade trigger asynchronous by scheduling a timer to downgrade the group in the appendFuture of the coordinator result. To avoid duplication, the rebalance is only triggered after the downgrade conversion but not after the last consumer protocol member leaves the group. If the downgrade is triggered by static member replacement, no rebalance will be triggered. 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
