【文件属性】：
文件名称：rocketmq-flume:用于RocketMQ与Flume-ng之间的消息接收和投递
文件大小：14KB
文件格式：ZIP
更新时间：2021-05-21 18:53:05
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)