Spark實戰（二）：Kafka-SparkStreaming-Elasticsearch

本文介紹saprk實時部分----spark-streaming。spark-streaming能夠實現實時批處理功能，實際上仍是至關於小的批處理，可是是7*24工做，能夠近實時但須要維護成本。本文裏的用java寫的demo，實現功能是將kafka做爲spark-streaming的輸入源，Elasticsearch做爲輸出源來實現實時處理架構。html 仍是先上代碼 mavenjava <dep

>>阅读原文<<