【文件属性】：
文件名称：flume-ng-kafka-sink
文件大小：15KB
文件格式：ZIP
更新时间：2021-06-13 14:06:42
Java
水槽-ng-kafka-sink
注意flume-ng-kafka-sink 已合并到即将发布的flume 1.6 中。 这个 repo不会在维护中。
该项目用于 与进行通信。
Kafka Sink的配置
agent_log.sinks.kafka.type = com.vipshop.flume.sink.kafka.KafkaSink
agent_log.sinks.kafka.channel = all_channel
agent_log.sinks.kafka.zk.connect = 127.0.0.1:2181
agent_log.sinks.kafka.topic = all
agent_log.sinks.kafka.batchsize = 200
agent_log.sinks.kafka.producer.type = async
agent_log.sinks.
【文件预览】：
flume-ng-kafka-sink-master
----.project(548B)
----src()
--------test()
--------main()
----LICENSE(11KB)
----README.md(959B)
----pom.xml(1KB)
----.gitignore(121B)