使用SparkStreaming+Kafka+Flume的實現wordcount一個簡單的小項目

使用SparkStreaming+Kafka+Flume的一個簡單的小項目 整體架構用Flume採集數據源下沉到Kafak中，再用SparkStreamming對數據做一個簡單的WordCount; 下面是具體代碼： 1.Flume的conf的配置 #爲我們的source channel sink起名 a1.sources=r1 a1.channels=c1 a1.sinks=k1 #指定我們的s

>>阅读原文<<