系統(tǒng)運(yùn)維

Leader：領(lǐng)導(dǎo)者角色，主要負(fù)責(zé)投票的發(fā)起和決議，以及更新系統(tǒng)狀態(tài)。
follower：跟隨著角色，用于接收客戶端的請求并返回結(jié)果給客戶端，在選舉過程中參與投票。
observer：觀察者角色，用戶接收客戶端的請求，并將寫請求轉(zhuǎn)發(fā)給leader，同時(shí)同步leader狀態(tài)，但是不參與投票。Observer目的是擴(kuò)展系統(tǒng)，提高伸縮性。
client：客戶端角色，用于向zookeeper發(fā)起請求。

Broker：Kafka集群包含一個(gè)或多個(gè)服務(wù)器，每個(gè)服務(wù)器被稱為broker。
Topic：每條發(fā)布到Kafka集群的消息都有一個(gè)分類，這個(gè)類別被稱為Topic（主題）。
Producer：指消息的生產(chǎn)者，負(fù)責(zé)發(fā)布消息到kafka?broker。
Consumer：指消息的消費(fèi)者，從kafka?broker拉取數(shù)據(jù)，并消費(fèi)這些已發(fā)布的消息。
Partition：Partition是物理上的概念，每個(gè)Topic包含一個(gè)或多個(gè)Partition，每個(gè)partition都是一個(gè)有序的隊(duì)列。partition中的每條消息都會被分配一個(gè)有序的id（offset）。
Consumer?Group：消費(fèi)者組，可以給每個(gè)Consumer指定消費(fèi)組，若不指定消費(fèi)者組，則屬于默認(rèn)的group。
Message：消息，通信的基本單位，每個(gè)producer可以向一個(gè)topic發(fā)布一些消息。

Kafka中的Producer和consumer采用的是push、pull的模式，即producer向?broker進(jìn)行push消息，comsumer從bork進(jìn)行pull消息，push和pull對于消息的生產(chǎn)和消費(fèi)是異步進(jìn)行的。pull模式的一個(gè)好處是consumer可自主控制消費(fèi)消息的速率，同時(shí)consumer還可以自己控制消費(fèi)消息的方式是批量的從broker拉取數(shù)據(jù)還是逐條消費(fèi)數(shù)據(jù)。

讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來自于我們對這個(gè)行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長期合作伙伴，公司提供的服務(wù)項(xiàng)目有：主機(jī)域名、網(wǎng)站空間、營銷軟件、網(wǎng)站建設(shè)、襄垣網(wǎng)站維護(hù)、網(wǎng)站推廣。

分享名稱：Zookeeper與Kafka基礎(chǔ)概念和原理
鏈接分享：http://m.rwnh.cn/article34/cgeipe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供自適應(yīng)網(wǎng)站、網(wǎng)站建設(shè)、虛擬主機(jī)、微信公眾號、標(biāo)簽優(yōu)化、網(wǎng)站導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)