spark createDirectStream保存kafka offset(JAVA實現)

問題描述 原文地址：http://blog.csdn.net/xueba207/article/details/50381821 最近使用Spark streaming處理kafka的數據，業務數據量比較大，就使用了KafkaUtils的createDirectStream()方式，此方法直接從kafka的broker的分區中讀取數據，跳過了zookeeper，並且沒有receiver，是spar

>>阅读原文<<