Spark Streaming整合kafka實戰

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