【文件属性】:
文件名称:udp-kafka-bridge:简单的守护程序将UDP消息传递给Kafka
文件大小:10KB
文件格式:ZIP
更新时间:2021-05-04 18:21:03
Scala
UDP-Kafka-桥
将从指定的UDP端口接收的任何消息发送到指定的主题。 我们使用它将系统日志消息推送到kafka。
下载
跑步
要侦听端口10514并在本地代理上使用mytopic ,只需运行:
java -jar udp-kafka-bridge-assembly-0.1.jar
要修改默认值,您可以使用java系统属性,例如:
java \
-Dbind.host=0.0.0.0 \
-Dbind.port=10514 \
-Dtopic=mytopic \
-Dkafka.metadata.broker.list=localhost:9092 \
-Dkafka.serializer.class=kafka.serializer.StringEncoder \
-Dkafka.compression.codec=1 \
-Dkafka.producer.type=async
【文件预览】:
udp-kafka-bridge-master
----.gitignore(173B)
----project()
--------plugins.sbt(58B)
--------build.properties(20B)
----src()
--------main()
----LICENSE(10KB)
----README.md(2KB)
----build.sbt(945B)