Skip to content

AutoPreferredReplicaLeaderElection

State

AutoPreferredReplicaLeaderElection is a ControllerEvent that transition the KafkaController to AutoLeaderBalance state.

AutoPreferredReplicaLeaderElection is enqueued (to the ControllerEventManager) exclusively from the <>.

Process

When processed on a controller broker, AutoPreferredReplicaLeaderElection event checkAndTriggerAutoLeaderRebalance and in the end scheduleAutoLeaderRebalanceTask with the delay based on leader.imbalance.check.interval.seconds configuration property.

Note

AutoPreferredReplicaLeaderElection event is ignored (skipped) when processed on any broker but controller broker.