jsancio opened a new pull request #11893: URL: https://github.com/apache/kafka/pull/11893
Implement auto leader rebalance for KRaft by keeping track of the set of topic partitions which have a leader that is not the preferred replica. If this set is non-empty then schedule a leader balance event for the replica control manager. When applying `PartitionRecord`s and `PartitionChangeRecord`s to the `ReplicationControlManager`, if the elected leader is not the preferred replica then remember this topic partition in the set of `imbalancedPartitions`. Anytime the quorum controller processes a `ControllerWriteEvent` it schedules a rebalance operation if the there are no pending rebalance operations, the feature is enabled and there are imbalance partitions. This KRaft implementation only supports the configurations properties `auto.leader.rebalance.enable` and `leader.imbalance.check.interval.seconds`. The configuration property `leader.imbalance.per.broker.percentage` is not supported and ignored. ### 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
