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