文件名称：flume-ng-kafka-sink:将数据发布到 Apache Kafka 的 Apache Flume Sink 实现
文件大小：416KB
文件格式：ZIP
更新时间：2024-07-02 23:04:43
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)