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

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