【文件属性】：
文件名称：flume-ng-kafka-source
文件大小：15KB
文件格式：ZIP
更新时间：2021-06-13 14:06:44
Java
水槽-ng-kafka-源
注意flume-ng-kafka-source 已合并到即将发布的flume 1.6 中。 这个 repo不会在维护中。
该项目用于 与进行通信。
Kafka源码配置
agent_log.sources.kafka0.type = com.vipshop.flume.source.kafka.KafkaSource
agent_log.sources.kafka0.zk.connect = 127.0.0.1:2181
agent_log.sources.kafka0.topic = all
agent_log.sources.kafka0.groupid = es
agent_log.sources.kafka0.channels = channel0
特别感谢
事实上，我是 Java 的新手。 我从学到了很多。 感谢 。
【文件预览】：
flume-ng-kafka-source-master
----pom.xml(1KB)
----LICENSE(11KB)
----src()
--------test()
--------main()
----.gitignore(121B)
----README.md(854B)