【文件属性】：
文件名称：flume-ng-kafka-sink:将数据发布到 Apache Kafka 的 Apache Flume Sink 实现
文件大小：416KB
文件格式：ZIP
更新时间：2021-06-13 05:18:03
Java
Flume-NG-Kafka-Sink
这是一个 Sink 实现，可以将数据发布到主题。 目标是将 Flume 与 Kafka 集成，以便基于拉式的处理系统（如可以处理来自各种 Flume 源（如 Syslog）的数据。
这现在是官方 Flume 发行版（从 v1.6 开始）的一部分，并有重大改进。
更新
2014 年 8 月 23 日 - 此实现作为一项新功能提交给 Apache Flume。 此功能的关联 Jira -
2014 年 8 月 17 日 - 添加了单元测试并与构建链接。
示例用例
使用 Apache Flume、Apache Kafka 和 Apache Storm 的实时 Syslog 处理架构。
依赖版本
Apache Flume - 1.5.0
Apache Kafka - 0.8.1.1
先决条件
Java 1.6 或更高版本
安装（请参阅上面的依赖版本）
【文件预览】：
flume-ng-kafka-sink-master
----conf()
--------flume-kafka.conf(951B)
----impl()
--------src()
--------pom.xml(2KB)
----example()
--------src()
--------pom.xml(2KB)
----LICENSE(11KB)
----README.md(6KB)
----dist()
--------src()
--------pom.xml(3KB)
----pom.xml(3KB)
----.gitignore(279B)
----realtime-syslog-processing-archi.png(514KB)