Flume-ng 插件,使用 Redis 列表,带有拉模式源和 Ack 模式接收器
Flume-ng ( )。 该插件基于 Apache Flume 1.5.0.1 和 Redis 2.8.17。
特征
使用 Redis 命令的源列表拉模式
使用 Redis 命令以 ack-mode 接收
用法
构建或下载 jar。 使用mvn clean package检出和构建
将flumeng-plugins-redis-[VERSION].jar或flumeng-plugins-redis-[VERSION]-jar-with-dependencies.jar复制到您的flume 库路径中。
复制或创建配置文件或示例配置文件到某个地方(源和接收器使用的redis列表必须是同一个redis实例)。
跑步。 以下推荐是 RedisListPollableSource 的示例
bin/flu
2021-06-21 14:05:50
8KB
Java
1