文件名称：rocketmq-flume-master:flume收集日志发送到rocketmq
文件大小：27.71MB
文件格式：ZIP
更新时间：2024-07-14 21:10:32
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-master
----rocketmq-flume-sink()
--------src()
--------target()
--------pom.xml(486B)
--------rocketmq-flume-sink.iml(4KB)
----wjgo1q5s.2yd.txt.bak(8KB)
----README.md(5KB)
----pom.xml(2KB)
----rocketmq-flume-source()
--------rocketmq-flume-source.iml(4KB)
--------src()
--------target()
--------pom.xml(488B)