杭州网站快速备案百度指数下载app

 kafka集群在启动时，会将每个broker节点注册到zookeeper中，每个broker节点都有一个controller，哪个controller先在zookeeper中注册，哪个controller就负责监听brokers节点变化，当有分区的leader挂掉时，controller会监听到节点变化，然后去zookeeper中获取isr，选举新的leader，选举的规则是：在isr中存活为前提，按照AR中排在前面的优先。选举完成后，controller会更新zookeeper中的leader和isr信息。