這幾天折騰spark的kafka的低階API createDirectStream的一些總結。

你們都知道在spark1.3版本後，kafkautil裏面提供了兩個建立dstream的方法，一個是老版本中有的createStream方法，還有一個是後面新加的createDirectStream方法。關於這兩個方法的優缺點，官方已經說的很詳細(http://spark.apache.org/docs/latest/streaming-kafka-integration.html)，總之就是cr

>>阅读原文<<