rondagostino opened a new pull request #10008: URL: https://github.com/apache/kafka/pull/10008
The group coordinator currently queries ZooKeeper to retrieve the partition count for the `__consumer_offsets` topic. ZooKeeper won't be available when the broker is using a Raft-based metadata quorum, so we instead provide the partition count directly upon invoking `groupCoordinator.startup()` rather than providing a ZooKeeper client upon construction; we therefore allow the broker to decide how to get the partition count instead of having the group coordinator being responsible for doing it (and having to know whether we are using ZooKeeper or not). A ZooKeeper-based broker will still query ZooKeeper, whereas a broker using a Raft-based metadata quorum will have caught up on the metadata log before invoking `groupCoordinator.startup()` and can provide the partition count at that time. Existing tests are sufficient to prevent bugs and regressions. ### 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
