KafkaController的状态机和partition leader选择器

Partition:Topic的分区
Partition状态机
KafkaController的状态机和partition leader选择器


Replica:存放Partition复制品的broker(kafka server实例)
Replica状态机
KafkaController的状态机和partition leader选择器


为partition选举新leader的4种选择器

ControlledShutdownLeaderSelector
KafkaController的状态机和partition leader选择器


OfflinePartitionLeaderSelector
KafkaController的状态机和partition leader选择器


PreferredReplicaPartitionLeaderSelector
KafkaController的状态机和partition leader选择器


ReassignedPartitionLeaderSelector
KafkaController的状态机和partition leader选择器