第一種模式：
點(diǎn)對(duì)點(diǎn)模式（一對(duì)一，消費(fèi)者主動(dòng)拉取數(shù)據(jù)，消息收到后消息清除）
1.消息生產(chǎn)者生產(chǎn)消息發(fā)送給隊(duì)列，然后消費(fèi)者從隊(duì)列中取出并且消費(fèi)消息
2.消息被消費(fèi)以后，queue中不再有存儲(chǔ)，所有消息消費(fèi)者不可能消費(fèi)到已經(jīng)被消費(fèi)的消息
3.隊(duì)列支持多個(gè)消費(fèi)者，但對(duì)一個(gè)消息而言，只有一個(gè)消費(fèi)者可以消費(fèi)。
第二種模式：
發(fā)布訂閱模式
1.消息生產(chǎn)者將消息發(fā)到topic,可以有多個(gè)topic.
2.同時(shí)有多個(gè)消息消費(fèi)者訂閱消費(fèi)該消息，消費(fèi)數(shù)據(jù)后不會(huì)被刪除。
3.每個(gè)消費(fèi)者相互獨(dú)立，都可以消費(fèi)到數(shù)據(jù)。

kafka中的一些名詞：
主題：事件被組織持久的存儲(chǔ)在主題中。kafka中的主題始終是多生產(chǎn)者和多訂閱者：一個(gè)主題可以N個(gè)向其寫(xiě)入事件的生產(chǎn)者，以及訂閱這些事件的N個(gè)消費(fèi)者。主題中的事件可以根據(jù)需要隨時(shí)讀取雨傳統(tǒng)的消息傳遞系統(tǒng)不同，事件被消費(fèi)后不會(huì)被刪除，相反，您可以通過(guò)每個(gè)主題的配置設(shè)置來(lái)定義kafka應(yīng)該將你的事件保存多久，之后老的事件被丟棄。kafka適合長(zhǎng)時(shí)間存儲(chǔ)數(shù)據(jù)。

broker:主要功能就是持久化消息以及將消息隊(duì)列中的消息從發(fā)送端傳輸?shù)较M(fèi)端。一個(gè)broker通常以服務(wù)器的形式出現(xiàn)，一臺(tái)kafka服務(wù)器就是一個(gè)broker.一個(gè)集群由多個(gè)broker組成。一個(gè)broker可以容納多個(gè)topic.如果kafka只有一個(gè)broker,就會(huì)出現(xiàn)單點(diǎn)故障。

一個(gè)分區(qū)只能被同一個(gè)消費(fèi)這組中的消費(fèi)者消費(fèi)

啟動(dòng)
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
生產(chǎn)者：kafka-console-producer.sh
消費(fèi)者：kafka-console-consumer.sh
topic:kafka-topic.sh