storm链接kafka时需要导入kafka、storm和storm链接kafka的jar包外,还需要这些jar包的支持
2021-12-11 22:03:48 2.47MB storm-kafka
1
风暴卡夫卡 风暴拓扑将风暴与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.
2021-12-07 11:10:02 136KB Java
1
在开发时候导入这个包和storm、kafka的核心包即可
2021-07-02 11:36:55 24.18MB storm-kafka jar包
1
此项目不再维护 有关最新信息,请参阅 。 Storm-kafka-hdfs-starter 提供使用 KafkaSpout 和 HdfsBolt 的示例
2021-07-02 11:03:08 28KB Java
1