您現(xiàn)在的位置: 首頁 > 標(biāo)簽 > 網(wǎng)絡(luò)從協(xié)調(diào)器
網(wǎng)絡(luò)從協(xié)調(diào)器
網(wǎng)絡(luò)從協(xié)調(diào)器
相關(guān)文章 : 0篇 瀏覽 : 次

顧名思義,協(xié)調(diào)器負(fù)責(zé)協(xié)調(diào)工作。本節(jié)所講的協(xié)調(diào)器,是用來協(xié)調(diào)消費者工作分配的。簡單點說,就是消費者啟動后,到可以正常消費前,這個階段的初始化工作。消費者能夠正常運轉(zhuǎn)起來,全有賴于協(xié)調(diào)器。 主要的協(xié)調(diào)器有如下兩個: 1、消費者協(xié)調(diào)器(ConsumerCoordinator) 2、組協(xié)調(diào)器(GroupCoordinator) 此外還有任務(wù)管理協(xié)調(diào)器(WorkCoordinator),用作kafka connect的works管理,本教程不做講解。 kafka引入?yún)f(xié)調(diào)器有其歷史過程,原來consumer信息依賴于zookeeper存儲,當(dāng)代理或消費者發(fā)生變化時,引發(fā)消費者平衡,此時消費者之間是互不透明的,每個消費者和zookeeper單獨通信,容易造成羊群效應(yīng)和腦裂問題。