1 、 broker管理之leo hw 含義 41}
leo : log and offset 每partion 收到1條消息都更新自己的 offset
leo = offset +1
Hw :高水位 LEO 功能是更新hw ,如果follower和leader的 leo 同步了hw就可以更新
hw 之前的消息對(duì)消費(fèi)者可見(jiàn),是commit的
2、 leo更新 42}
follwer 帶上自己的leo 去拉副本,更新leader的leo記錄
3、 hw 更新 43}
leader: hw 取leo 最小值
follower: 自己leo 和 leader 的leo的最小值
4、controller 管理集群 44}
競(jìng)爭(zhēng)在zk上創(chuàng)建目錄,最先成功的是controller
通過(guò)監(jiān)聽(tīng)zk的 很多目錄,讀取集群元數(shù)據(jù),分發(fā)給其他broker
zk目錄:
/broker/ids/0,1,2 感知上下線
/broker/topics 創(chuàng)建主題
/admin/reassign_partitions 分區(qū)重新分配
5、 延時(shí)任務(wù) 45}

image.png
6、時(shí)間輪 46} 0:10

image.png

image.png