網(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)題。
推薦產(chǎn)品
列表欄目