Kafka Consumer多線程實例

Kafka 0.9版本開始推出了Java版本的consumer，優化了coordinator的設計以及擺脫了對zookeeper的依賴。社區最近也在探討正式用這套consumer API替換Scala版本的consumer的計劃。鑑於目前這方面的資料並不是很多，本文將嘗試給出一個利用KafkaConsumer編寫的多線程消費者實例，希望對大家有所幫助。     這套API最重要的入口就是Kafka

>>阅读原文<<