【文件属性】：
文件名称：jet-kafka-to-influx:使用Hazelcast Jet从Kafka到InfluxDB聚合
文件大小：18KB
文件格式：ZIP
更新时间：2024-05-31 10:32:14
Java
用法
java -jar kafka-to-influxdb.jar
-本地或CLUSTER，默认为LOCAL
配置
您需要安装Kafka和influxDB。 您可以相应地在resources文件夹下修改source.properties和sink.properties 。
本地跑步
编译代码： mvn package
运行jar： java -jar target/kafka-to-influxdb.jar
这将创建一个嵌入并运行作业的2节点Jet集群。
集群运行
编译代码： mvn package
将Hazelcast Jet发行版下载到所有服务器： ://jet.hazelcast.org/download/
使用分发中的启动脚本运行每个节点： ./jet-start.sh
使用提交./jet-submit.sh kafka-to
【文件预览】：
jet-kafka-to-influx-master
----pom.xml(4KB)
----src()
--------test()
--------.DS_Store(8KB)
--------main()
----.gitignore(2KB)
----README.md(777B)
