最新版windows elasticsearch-7.16.0-windows-x86_64.zip
2021-12-09 13:03:14
320.04MB
1
最新版linux elasticsearch-7.16.0-linux-x86_64.tar.gz
2021-12-09 13:03:14
326.92MB
1
elasticsearch-analysis-pinyin-7.6.1.zip
2021-12-07 19:03:23
7.7MB
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
1
从AlertManager接收HTTP webhook通知，并将它们插入到Elasticsearch索引中进行搜索和分析
2021-12-07 10:31:03
257KB
1
消费kafka数据，然后批量导入到Elasticsearch,本例子使用的kafka版本0.10，es版本是6.4，使用bulk方式批量导入到es中，也可以一条一条的导入，不过比较慢。
org.elasticsearch
elasticsearch
6.4.0
org.elasticsearch.client
elasticsearch-rest-high-level-client
6.4.0
org.elasticsearch.client
transport
6.4.0
org.apache.kafka
kafka-clients
0.10.1.0
2021-12-06 11:27:21
9KB
1