Partition Leader Election
Partition Leader Election is a process of electing a broker to be the leader of a partition.
Use kafka-leader-election.sh utility for preferred or unclean leader election.
|Consult Demo: Using kafka-leader-election.sh.|
state-change.log) to trace the process in the logs.
Internally, Kafka controller uses Election utility (and PartitionLeaderElectionAlgorithms) for the algorithms for partition leader election.
Unclean Partition Leader Election
Unclean Partition Leader Election allows a non-ISR replica to be elected as a partition leader (as the last resort, even though doing so may result in data loss).
unclean.leader.election.enable configuration property is used to enable it cluster-wide (for any topic) or per topic.
Enable INFO logging level for kafka.controller.KafkaController logger to observe the process in the logs.