SparkStreaming整合kafka實踐

         kafka作爲一個實時的分佈式消息隊列,實時的生產和消費消息,這裏我們可以 1.KafkaUils.createDstream方式:利用SparkStreaming實時計算框架實時的讀取kafka中的數據然後進行計算。在spark1.3版本後,kafkaUtils裏面提供了兩個創建dstream的方法,一種爲KafkaUtils.createDstream,另一種爲KafkaUt
相關文章
相關標籤/搜索