Apache kafka 簡介

 kafka是一種高吞吐量的分佈式發佈訂閱消息系統,它能夠處理消費者規模的網站中的全部動做流數據服務器

kafka名詞解釋架構

Broker:Kafka 集羣包含一個或多個服務器,這種服務器被稱爲 broker。分佈式

Topic:每條發佈到 Kafka 集羣的消息都有一個類別,這個類別被稱爲 Topic。(物理上不一樣 Topic 的消息分開存儲,邏輯上一個 Topic 的消息雖然保存於一個或多個 broker 上,但用戶只需指定消息的 Topic 便可生產或消費數據而沒必要關心數據存於何處)。網站

Partition:Partition 是物理上的概念,每一個 Topic 包含一個或多個 Partition。隊列

Producer:負責發佈消息到 Kafka broker。kafka

Consumer:消息消費者,向 Kafka broker 讀取消息的客戶端。it

Consumer Group:每一個 Consumer 屬於一個特定的 Consumer Group(可爲每一個 Consumer 指定 group name,若不指定 group name 則屬於默認的 group)。io

每一個消息(也叫做record記錄,也被稱爲消息)是由一個key,一個value和時間戳構成。集羣

基本原理及架構原理

消息模型能夠分爲兩種:隊列和發佈-訂閱式。隊列的處理方式是一組消費者從服務器讀取消息,一條消息只有其中的一個消費者來處理。在發佈-訂閱模型中,消息被廣播給全部的消費者,接收到消息的消費者均可以處理此消息。

相關文章
相關標籤/搜索