【文件属性】：
文件名称：stream-processing-engine:这是使用Spark Streaming，Kafka和Elasticsearch进行实时流处理的示例
文件大小：1.13MB
文件格式：ZIP
更新时间：2021-05-09 14:05:32
elasticsearch scala kafka akka spark
流处理引擎
这是使用Spark Streaming，Kafka和Elasticsearch进行近实时流处理的示例。
此项目的先决条件
Elasticsearch设置
i）Elasticsearch 6.3.0或最新版本并将其解压缩。
ii）运行以下命令。
$ bin/elasticsearch
Kafka设置
i）Kafka-0.10.0.1或最新版本并解压缩。
ii）运行以下命令以启动Zookeeper和Kafka：
$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-server-start.sh config/server.properties
入门：
克隆并以本地模式运行：
$ git clone git@github.com:techmonad/st
【文件预览】：
stream-processing-engine-master
----es-mapping()
--------mapping.sh(781B)
----src()
--------test()
--------main()
----build.sbt(525B)
----doc()
--------stream_processing.png(128KB)
----.gitignore(316B)
----libexec()
--------activator-launch-1.3.10.jar(1.15MB)
----project()
--------build.properties(132B)
----README.md(1KB)