文件名称：Storm-Kafka-ES:风暴拓扑将风暴与Kafka和Elasticsearch集成
文件大小：136KB
文件格式：ZIP
更新时间：2024-06-02 08:57:35
Java
风暴卡夫卡 风暴拓扑将风暴与Kafka和Elasticsearch集成 该Storm拓扑使用Kafka Spout读取来自Kafka的消息，并使用Bolt将从Kafka读取的传入消息解析为JSON消息。 然后将已解析的JSON消息加载到Elastic搜索中以使用Kibana进行仪表板和分析 该项目的前提条件：Zookeeper安装Kafka Broker Storm安装并启动Nimbus，Supervisor，Logviewer和UI Elastic search Kibana（用于仪表板） 设置：安装完上述工具集后，将maven项目下载到本地工作区中并构建一个jar 执行：风暴罐/Storm-Kafka-ES-Integration/target/StormKafkaESIntegration-0.0.1-SNAPSHOT-jar-with-dependencies.jar com.
【文件预览】：
Storm-Kafka-ES-master
----README.md(797B)
----Storm-Kafka-ES-Integration()
--------src()
--------pom.xml(3KB)