Spark实战（二）：Kafka-SparkStreaming-Elasticsearch

本文介绍saprk实时部分----spark-streaming。spark-streaming能够实现实时批处理功能，实际上仍是至关于小的批处理，可是是7*24工做，能够近实时但须要维护成本。本文里的用java写的demo，实现功能是将kafka做为spark-streaming的输入源，Elasticsearch做为输出源来实现实时处理架构。html 仍是先上代码 mavenjava <dep

>>阅读原文<<