标签：broker ZK controller Kafka Controller Handler 节点
选举
controller的选举依赖于ZK，在Kafka集群启动的时候，会在ZK中创建一个临时节点/controller，每个broker启动时(broker 启动过程中会启动 controller 服务，其中涉及监听 ZK节点/controller的数据变化和选举逻辑等)，都会先去访问ZK中的这个节点；如果不存在broker就会去创建这个节点，先到先得成为controller。
[zk: localhost:2181(CONNECTED) 3] get /controller
{"version":1,"brokerid":0,"timestamp":"1608173427409"}功能
监听分区相关的变化
-
为ZK中的/admin/reassign_partitions节点注册监听器Handler来处理分区reassignment
-
为/isr_change_notification节点注册Handler来处理ISR副本集合的变更
监听主题相关的变化
-
为/brokers/topics节点注册Handler来处理主题的增减
-
为/admin/delete_topics节点注册Handler来处理主题的删除动作
监听Broker的变化
-
为/brokers/ids节点注册Handler来处理broker的增减
从ZK中获取broker、topic、partition相关的元数据信息
-
为/brokers/topics/<topic>节点注册Handler来处理topic中分区分配的变化
启动并管理分区状态机和副本状态机
更新集群的元数据信息,并同步给其它的Broker
Reference
标签：broker,ZK,controller,Kafka,Controller,Handler,节点 来源： https://blog.csdn.net/qq_34276652/article/details/121406534
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。