文件名称：rocketmq-flume:用于RocketMQ与Flume-ng之间的消息接收和投递
文件大小：14KB
文件格式：ZIP
更新时间：2024-06-10 12:39:45
Java
rocketmq-flume Source&Sink 该项目用于与之间的消息接收和投递。 首先请确定您已经对和有了基本的了解 确保本地maven库中已经存在，或者下载RocketMQ源码自行编译 在rocketmq-flume项目根目录执行mvn clean install dependency:copy-dependencies 将rocketmq-flume相关依赖jar包拷贝到$FLUME_HOME/lib目录中(具体包会在后面描述) Sink Sink配置说明 配置项 必填 默认值 说明 namesrvAddr 必填 null Name Server地址，遵循RocketMQ配置方式 producerGroup 可选 DEFAULT_PRODUCER Producer分组 topic 必填 null Topic名称 tags 可选 空字符串 Tag名称，遵循RocketMQ配置方式
【文件预览】：
rocketmq-flume-master
----rocketmq-flume-sink()
--------src()
--------pom.xml(487B)
----README.md(5KB)
----pom.xml(3KB)
----rocketmq-flume-source()
--------src()
--------pom.xml(489B)
----.gitignore(57B)