全部課程
發(fā)布時間: 2019-08-30 16:24:30
Kafka和其他組件比較,具有消息持久化、高吞吐、實(shí)時等特性,適用于離線和實(shí)時的消息消費(fèi),如網(wǎng)站活性跟蹤、聚合統(tǒng)計系統(tǒng)運(yùn)營數(shù)據(jù)(監(jiān)控數(shù)據(jù))、日志收集等大量數(shù)據(jù)的數(shù)據(jù)收集場景。

Consumer:消息消費(fèi)者,從Kafka Broker讀取消息的客戶端。
?
圖片中的藍(lán)色框為Kafka的一個Topic,即可以理解為一個隊列,每個格子代表一條消息。生產(chǎn)者產(chǎn)生的消息逐條放到Topic的末尾。消費(fèi)者從左至右順序讀取消息,使用Offset來記錄讀取的位置。
?
Kafka Partition
每個Topic 都有一個或者多個Partitions構(gòu)成。每個Partition都是有序且不可變的消息隊列。引入Partition機(jī)制,保證了Kafka的高吞吐能力。引入Partition機(jī)制,保證了Kafka的高吞吐能力,因為Topic的多個Partition分布在不同的Kafka節(jié)點(diǎn)上,這樣一來多個客戶端(Producer和Consumer)就可以并發(fā)訪問不同的節(jié)點(diǎn)對一個Topic進(jìn)行消息的讀寫。
?
上一篇: Java培訓(xùn)_SpringCloud構(gòu)建模塊化工程實(shí)現(xiàn)全局版本控制
下一篇: 人工智能AI培訓(xùn)_中文文本分詞