spark筆記之Spark Streaming整合kafka實戰

kafka作爲一個實時的分佈式消息隊列，實時的生產和消費消息，這裏我們可以利用SparkStreaming實時地讀取kafka中的數據，然後進行相關計算。 在Spark1.3版本後，KafkaUtils裏面提供了兩個創建dstream的方法，一種爲KafkaUtils.createDstream，另一種爲KafkaUtils.createDirectStream。 7.1 KafkaUtils.c

>>阅读原文<<