Spark Streaming(05)——Spark Streaming與kafka整合

在Spark1.3版本後,KafkaUtils裏面提供了兩個創建dstream的方法,一種爲KafkaUtils.createDstream,另一種爲KafkaUtils.createDirectStream。 KafkaUtils.createDstream方式 KafkaUtils.createDstream(ssc, [zk], [group id], [per-topic,partitio
相關文章
相關標籤/搜索