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

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

broker:主要功能就是持久化消息以及將消息隊列中的消息從發(fā)送端傳輸到消費端。一個broker通常以服務器的形式出現，一臺kafka服務器就是一個broker.一個集群由多個broker組成。一個broker可以容納多個topic.如果kafka只有一個broker,就會出現單點故障。

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

啟動
kafka-server-start.sh -daemon /opt/kafka/config/server.properties
生產者：kafka-console-producer.sh
消費者：kafka-console-consumer.sh
topic:kafka-topic.sh