kafka深度分析

1、Kafka深度分析（2）Exactlyoncemessagetransfer怎樣記錄每個consumer處理的信息的狀態(tài)？在Kafka中僅保存了每個consumer已經處理數據的offset。這樣有兩個好處：1）保存的數據量少2）當consumer出錯時，重新啟動consumer處理數據時，只需從最近的offset開始處理數據即可。（3）PushpullProducer向Kafka（push）推數據，consumer從kafka拉（pu

2、ll）數據。（4）負載均衡和容錯）負載均衡和容錯Producer和broker之間沒有負載均衡機制。broker和consumer之間利用zookeeper進行負載均衡。所有broker和consumer都會在zookeeper中進行注冊，且zookeeper會保存他們的一些元數據信息。如果某個broker和consumer發(fā)生了變化，所有其他的broker和consumer都會得到通知。kafka術語術語TopicTopicTopic

3、是KAFKA對消息分類的依據一條消息必須有一個與之對應的Topic比如現在又兩個Topic分別是TopicA和TopicBProducer向TopicA發(fā)送一個消息messageA然后向TopicB發(fā)送一個消息messaeB那么訂閱TopicA的Consumer就會收到消息messageA訂閱TopicB的Consumer就會收到消息messaeB(每個Consumer可以同時訂閱多個Topic也即是說同時訂閱TopicA和TopicB