文件名称：flume-ng-kafka-source
文件大小：15KB
文件格式：ZIP
更新时间：2024-07-03 07:53:24
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)