Broker_工作流程

通过Kafka broker上下线，观察Zookeeper 中数据变化

1. 查看/kafka/brokers/ids 路径上的节点。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 12] ls /kafka/brokers/ids
   [0, 1, 2]
   

2. 查看/kafka/controller节点上的数据。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 14] get /kafka/controller
   {"version":1,"brokerid":0,"timestamp":"1649207964072"}
   

3. 查看/kafka/brokers/topics/topicN/partitions/2/state 路径上的数据。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 15] get /kafka/brokers/topics/topicN/partitions/2/state
   {"controller_epoch":2,"leader":1,"version":1,"leader_epoch":0,"isr":[1,0,2]}
   

4. 停止node3上的 kafka。

   xxxxxxxxxx
   [root@node3 ~]# kafka-server-stop.sh
   [root@node3 ~]# jps
   18519 Jps
   2287 QuorumPeerMain
   

5. 再次查看/kafka/brokers/ids 路径上的节点。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 16] ls /kafka/brokers/ids
   [0, 2]
   

6. 再次查看/kafka/controller 路径上的数据。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 17] get /kafka/controller
   {"version":1,"brokerid":0,"timestamp":"1649207964072"}
   

7. 再次查看/kafka/brokers/topics/topicN/partitions/2/state 路径上的数据。

   xxxxxxxxxx
   [zk: node4:2181(CONNECTED) 18] get /kafka/brokers/topics/topicN/partitions/2/state
   {"controller_epoch":2,"leader":0,"version":1,"leader_epoch":1,"isr":[0,2]}
   

   leader值由1变为了0，leader_epoch+=1，isr去掉了1。

8. 启动 node3上的 kafka

   xxxxxxxxxx
   [root@node3 ~]# kafka-server-start.sh -daemon /opt/kafka/config/server.properties
   

9. 再次观察1,2,3步骤中的内容。

实时效果反馈

1. 关于Broker工作流程的描述，错误的是：

A broker启动时，会在节点/kafka/brokers/ids下注册子节点，每个子节点分别对应一个broker。

B 抢注临时节点/kafka/controller，注册成功的broker上的Controller为Leader,/kafka/controller_epoch节点的值默认为1，每次改变Controller Leader 它的值就会+1。

C Leader Controller监听/kafka/broker/ids子节点变化。

D Partition Leader的选举规则：1.首先是在isr列表中存活的节点;2.按照ar列表元素的前后顺序依次进行。

答案：

1=>B /kafka/controller_epoch节点的值默认为0。