讀取kafka 0.8 簡單例子

Kafka0.8和kafka0.7變化很是大，使用方式和接口class都變掉了。這裏簡單介紹一下0.8的kafka如何讀取數據。java 系統中的flume會把數據寫到kafka，爲了驗證數據的正確性，我就寫了一個讀取kafka的小程序。因此這個項目的主要意義是爲了作數據驗證，實際的生產環境的配置會比這個複雜。apache 我使用的是maven管理java項目。小程序 首先maven的depend

>>阅读原文<<