1. 程式人生 > >kafka:leader選舉

kafka:leader選舉

Kafka叢集Leader選舉原理

我們知道Zookeeper叢集中也有選舉機制,是通過Paxos演算法,通過不同節點向其他節點發送資訊來投票選舉出leader,但是Kafka的leader的選舉就沒有這麼複雜了。  Kafka的Leader選舉是通過在zookeeper上建立/controller臨時節點來實現leader選舉,並在該節點中寫入當前broker的資訊  {“version”:1,”brokerid”:1,”timestamp”:”1512018424988”}  利用Zookeeper的強一致性特性,一個節點只能被一個客戶端建立成功,建立成功的broker即為leader,即先到先得原則,leader也就是叢集中的controller,負責叢集中所有大小事務。  當leader和zookeeper失去連線時,臨時節點會刪除,而其他broker會監聽該節點的變化,當節點刪除時,其他broker會收到事件通知,重新發起leader選舉。 ---------------------  作者:v墨竹v  來源:CSDN  原文:https://blog.csdn.net/apei830/article/details/78773550?utm_source=copy  版權宣告:本文為博主原創文章,轉載請附上博文連結!