客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
开源软件名称：rocketmq-flume开源软件地址：https://gitee.com/mxb/rocketmq-flume开源软件介绍：rocketmq-flume Source&Sink该项目用于RocketMQ与Flume-ng之间的消息接收和投递。
SinkSink配置说明
Sink综合示例
agent1.sources=source1agent1.channels=channel1agent1.sinks=sink1agent1.sources.source1.type=avroagent1.sources.source1.bind=0.0.0.0agent1.sources.source1.port=15151agent1.sources.source1.channels=channel1agent1.sinks.sink1.type=com.handu.flume.sink.rocketmq.RocketMQSinkagent1.sinks.sink1.namesrvAddr=rocketmq_namesrv:9876agent1.sinks.sink1.producerGroup=MyProducerGroup_1agent1.sinks.sink1.topic=FromFlumeagent1.sinks.sink1.tag=Tag1agent1.sinks.sink1.channel=channel1agent1.channels.channel1.type=memoryagent1.channels.channel1.capacity=100agent1.channels.channel1.transactionCapacity=100agent1.channels.channel1.keep-alive=3
rocketmq-flume-sink-1.0.0.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target)fastjson-1.1.41.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)netty-all-4.0.23.Final.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-client-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-common-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-remoting-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)
shell1> $FLUME_HOME/bin/flume-ng agent -c conf -f conf/flume.conf -n agent1 -Dflume.root.logger=INFO,consoleshell2> $FLUME_HOME/bin/flume-ng avro-client -H localhost -p 15151 -F $FLUME_HOME/README
SourceSource配置说明
Source综合示例agent1.sources=source1agent1.channels=channel1agent1.sinks=sink1agent1.sources.source1.type=com.handu.flume.source.rocketmq.RocketMQSourceagent1.sources.source1.namesrvAddr=rocketmq_namesrv:9876agent1.sources.source1.consumerGroup=MyConsumerGroup_1agent1.sources.source1.topic=TopicTestagent1.sources.source1.tags=*agent1.sources.source1.messageModel=BROADCASTINGagent1.sources.source1.maxNums=32agent1.sources.source1.channels=channel1agent1.sinks.sink1.type=loggeragent1.sinks.sink1.channel=channel1agent1.channels.channel1.type=memoryagent1.channels.channel1.capacity=100agent1.channels.channel1.transactionCapacity=100agent1.channels.channel1.keep-alive=3
rocketmq-flume-source-1.0.0.jar (文件位置: $PROJECT_HOME/rocketmq-flume-source/target)fastjson-1.1.41.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)netty-all-4.0.23.Final.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-client-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-common-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)rocketmq-remoting-3.2.2.jar (文件位置: $PROJECT_HOME/rocketmq-flume-sink/target/dependency)
$FLUME_HOME/bin/flume-ng agent -c conf -f conf/flume.conf -n agent1 -Dflume.root.logger=INFO,console |
请发表评论