kafka的首領選舉

當控制器發(fā)現(xiàn)一個首領已經(jīng)離開集群,控制器遍歷分區(qū),并確定誰應該成為新首領(簡單來說就是分區(qū)副本列表里的下一個副本),然后向所有包含新首領和現(xiàn)有跟隨者的broker發(fā)送請求。

該請求消息包含了誰是新首領以及誰是分區(qū)跟隨者的信息。隨后,新首領開始處理來自生產(chǎn)者和消費者的請求,而跟隨者開始從新首領那里復制消息。

當控制器發(fā)現(xiàn)一個broker加入集群時,它會使用brokerID來檢查新加入的broker是否包含現(xiàn)有分區(qū)的副本。如果有,控制器就把變更通知發(fā)送給新加入的broker和其他broker,新broker上的副本開始從首領那里復制消息。

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

  • (一)kafka集群 1、集群成員關系 (1)broker如何將自己注冊到zookeeper上:broker啟動的...
    luohuan519閱讀 410評論 0 0
  • 這段時間一直斷斷續(xù)續(xù)地在看《Kafka權威指南》,深深為Kafka里面的架構設計理念所折服。一邊看的同時一邊設想面...
    二向箔與歌者閱讀 2,580評論 0 1
  • 簡介 Kafka從0.8.x版本開始引入副本機制,這樣可以極大的提高集群的可靠性和穩(wěn)定性。不過這也使得Kafka變...
    朱小廝閱讀 2,037評論 0 1
  • 代理節(jié)點處理控制器發(fā)送的LeaderAndIsr請求,服務端會交給副本管理器來處理。 創(chuàng)建分區(qū) 服務端處理Lead...
    紹圣閱讀 1,499評論 0 0
  • 集群成員關系 Kafka 使用 Zookeeper 來維護集群成員的信息。每個 broker 都有一個唯一標識符,...
    勤奮的碼農(nóng)閱讀 348評論 0 0

友情鏈接更多精彩內容