Spark Streaming 整合Flume 和Kafka

前言 首先會使用Java開發一個日誌產生器，使用Flume收集此信息到Kafka，然後Spark Streaming 從Kafka讀取消息。 完整項目代碼： https://github.com/GYT0313/Spark-Learning/tree/master/sparkstream 1. 日誌產生器 首先你應該創建一個Maven 項目，參考：http://www.javashuo.com/a

>>阅读原文<<