建站
咨詢
售后
建站咨詢
新聞中心
看看下面的插圖。 它顯示Kafka的集群圖。
創(chuàng)新互聯(lián)是一家專注于網(wǎng)站制作、成都網(wǎng)站建設(shè)與策劃設(shè)計,鼓樓網(wǎng)站建設(shè)哪家好?創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設(shè)十多年,網(wǎng)設(shè)計領(lǐng)域的專業(yè)建站公司;建站業(yè)務(wù)涵蓋:鼓樓等地區(qū)。鼓樓做網(wǎng)站價格咨詢:18982081108
下表描述了上圖中顯示的每個組件。
| S.No | 組件和說明 |
|---|---|
| 1 | Broker（代理） Kafka集群通常由多個代理組成以保持負(fù)載平衡。 Kafka代理是無狀態(tài)的，所以他們使用ZooKeeper來維護(hù)它們的集群狀態(tài)。 一個Kafka代理實例可以每秒處理數(shù)十萬次讀取和寫入，每個Broker可以處理TB的消息，而沒有性能影響。 Kafka經(jīng)紀(jì)人領(lǐng)導(dǎo)選舉可以由ZooKeeper完成。 |
| 2 | ZooKeeper ZooKeeper用于管理和協(xié)調(diào)Kafka代理。 ZooKeeper服務(wù)主要用于通知生產(chǎn)者和消費者Kafka系統(tǒng)中存在任何新代理或Kafka系統(tǒng)中代理失敗。 根據(jù)Zookeeper接收到關(guān)于代理的存在或失敗的通知，然后生產(chǎn)者和消費者采取決定并開始與某些其他代理協(xié)調(diào)他們的任務(wù)。 |
| 3 | Producers（生產(chǎn)者） 生產(chǎn)者將數(shù)據(jù)推送給經(jīng)紀(jì)人。 當(dāng)新代理啟動時，所有生產(chǎn)者搜索它并自動向該新代理發(fā)送消息。 Kafka生產(chǎn)者不等待來自代理的確認(rèn)，并且發(fā)送消息的速度與代理可以處理的一樣快。 |
| 4 | Consumers（消費者） 因為Kafka代理是無狀態(tài)的，這意味著消費者必須通過使用分區(qū)偏移來維護(hù)已經(jīng)消耗了多少消息。 如果消費者確認(rèn)特定的消息偏移，則意味著消費者已經(jīng)消費了所有先前的消息。 消費者向代理發(fā)出異步拉取請求，以具有準(zhǔn)備好消耗的字節(jié)緩沖區(qū)。 消費者可以簡單地通過提供偏移值來快退或跳到分區(qū)中的任何點。 消費者偏移值由ZooKeeper通知。 |
當(dāng)前題目：創(chuàng)新互聯(lián)ApacheKafka教程：ApacheKafka集群架構(gòu)
本文鏈接：http://www.fisionsoft.com.cn/article/cccdech.html
