?kafka集群在啟動時,會將每個broker節(jié)點注冊到zookeeper中,每個broker節(jié)點都有一個controller,哪個controller先在zookeeper中注冊,哪個controller就負責監(jiān)聽brokers節(jié)點變化,當有分區(qū)的leader掛掉時,controller會監(jiān)聽到節(jié)點變化,然后去zookeeper中獲取isr,選舉新的leader,選舉的規(guī)則是:在isr中存活為前提,按照AR中排在前面的優(yōu)先。選舉完成后,controller會更新zookeeper中的leader和isr信息。文章來源:http://www.zghlxwxcb.cn/news/detail-630703.html
文章來源地址http://www.zghlxwxcb.cn/news/detail-630703.html
到了這里,關于Kafka-Broker工作流程的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章,希望大家以后多多支持TOY模板網(wǎng)!