Kafka 0.9版本開始推出了Java版本的consumer，優化了coordinator的設計以及擺脫了對zookeeper的依賴。社區最近也在探討正式用這套consumer API替換Scala版本的consumer的計划。鑒於目前這方面的資料並不是很多，本文將嘗試給出一個 ...

　　在上一篇《Kafka Consumer多線程實例》中我們討論了KafkaConsumer多線程的兩種寫法：多KafkaConsumer多線程以及單KafkaConsumer多線程。在第二種用法中我使用的是自動提交的方式，省去了多線程提交位移的麻煩。很多人跑來問如果是手動提交應該怎么寫 ...

上一篇《Kafka Consumer多線程實例續篇》修正了多線程提交位移的問題，但依然可能出現數據丟失的情況，原因在於多個線程可能拿到相同分區的數據，而消費的順序會破壞消息本身在分區中的順序，因而擾亂位移的提交。這次我使用KafkaConsumer的pause和resume方法來防止這種情形的發生 ...

遷移到：http://www.itrensheng.com/archives/apache-kafka-kafka-connectfileconnector ...

　　為了更好的實現負載均衡和消息的順序性，Kafka Producer可以通過分發策略發送給指定的Partition。Kafka Java客戶端有默認的Partitioner，平均的向目標topic的各個Partition中生產數據，如果想要控制消息的分發策略，有兩種方式，一種是在發送前創建 ...

文章轉載自 五月的倉頡 大神, 原文地址:http://www.cnblogs.com/xrq730/p/5060921.html 前言 Java多線程分類中寫了21篇多線程的文章，21篇文章的內容很多，個人認為，學習，內容越多、越雜的知識，越需要進行深刻的總結，這樣才能記憶深刻 ...

了解了什么是kafka（ https://www.cnblogs.com/tree1123/p/11226880.html）以后 學習Kafka核心之消費者，kafka的消費者經過幾次版本變化，特別容易混亂，所以一定要搞清楚是哪個版本再研究。 一、舊版本consumer 只有舊版本（0.9 ...

我么知道Java傳統多線程的實現有兩種方法,繼承Thread類或者實現Runnable即可.線程啟動時調用start()方法. 實現Runnable接口相比繼承Thread類有如下好處: 1.避免單繼承的局限,一個類可以同時實現多個接口 2.適合資源的共享. 實現多線程模擬售票點賣票 ...