Kafka集群中的broker在zk中创建临时序号节点,序号最⼩的节点(最先创建的节点)将作为集群的controller,负责管理整个集群中的所有分区和副本的状态:
1、当某个分区的leader副本出现故障时,由控制器负责为该分区选举新的leader副本。
2、当检测到某个分区的ISR集合发⽣变化时,由控制器负责通知所有broker更新其元数据信息。
3、当使⽤kafka-topics.sh脚本为某个topic增加分区数量时,同样还是由控制器负责让新分区被其他节点感知到。
Kafka集群中的broker在zk中创建临时序号节点,序号最⼩的节点(最先创建的节点)将作为集群的controller,负责管理整个集群中的所有分区和副本的状态:
1、当某个分区的leader副本出现故障时,由控制器负责为该分区选举新的leader副本。
2、当检测到某个分区的ISR集合发⽣变化时,由控制器负责通知所有broker更新其元数据信息。
3、当使⽤kafka-topics.sh脚本为某个topic增加分区数量时,同样还是由控制器负责让新分区被其他节点感知到。