您現(xiàn)在的位置: 首頁(yè) > 標(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)器,是用來(lái)協(xié)調(diào)消費(fèi)者工作分配的。簡(jiǎn)單點(diǎn)說(shuō),就是消費(fèi)者啟動(dòng)后,到可以正常消費(fèi)前,這個(gè)階段的初始化工作。消費(fèi)者能夠正常運(yùn)轉(zhuǎn)起來(lái),全有賴于協(xié)調(diào)器。 主要的協(xié)調(diào)器有如下兩個(gè): 1、消費(fèi)者協(xié)調(diào)器(ConsumerCoordinator) 2、組協(xié)調(diào)器(GroupCoordinator) 此外還有任務(wù)管理協(xié)調(diào)器(WorkCoordinator),用作kafka connect的works管理,本教程不做講解。 kafka引入?yún)f(xié)調(diào)器有其歷史過(guò)程,原來(lái)consumer信息依賴于zookeeper存儲(chǔ),當(dāng)代理或消費(fèi)者發(fā)生變化時(shí),引發(fā)消費(fèi)者平衡,此時(shí)消費(fèi)者之間是互不透明的,每個(gè)消費(fèi)者和zookeeper單獨(dú)通信,容易造成羊群效應(yīng)和腦裂問(wèn)題。