Flume+kafka+SparkStreaming整合

1、需求 模擬一個流式處理場景：java 我再說話，我編寫好的一個spark streaming作詞頻統計apache 1.模擬說話 ： nc -lk 3399 flumebootstrap source :avro(qyl01:3399)app channel:memory框架 sink : kafkasinkoop 模擬實時的日誌生成：ui echo aa bb cc >> /home/qyl

>>阅读原文<<