文件名称：stream-processing-engine:这是使用Spark Streaming，Kafka和Elasticsearch进行实时流处理的示例
文件大小：1.13MB
文件格式：ZIP
更新时间：2024-05-29 07:52:12
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)