FlumeKafkaSink:Flume-ng Sink 插件生成到 Kafka

时间:2024-07-11 12:28:10
【文件属性】:

文件名称:FlumeKafkaSink:Flume-ng Sink 插件生成到 Kafka

文件大小:19KB

文件格式:ZIP

更新时间:2024-07-11 12:28:10

Java

FlumeKafkaSink 这个项目是汇插件生产,以 。 安装 // Assembly with dependencies mvn assembly:assembly -DskipTests=true Flume-NG 的配置 # example.conf: A single-node Flume configuration # Name the components on this agent a1.sources = r1 a1.sinks = k1 k2 a1.channels = c1 c2 # Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = 192.168.2.102 a1.sources.r1.port = 44444 a1.channels.c1.type =


【文件预览】:
FlumeKafkaSink-master
----src()
--------test()
--------main()
----LICENSE(11KB)
----README.md(1KB)
----pom.xml(3KB)
----.gitignore(130B)
----flume-ng-kafka-sink.iml(5KB)

网友评论