flume-ng-kafka-source

水槽-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 的新手。 我从学到了很多。 感谢 。