RocketMQ Runtime
快速构建并使用RocketMQ Runtime
RocketMQ Runtime 快速开始
环境依赖
64bit JDK 1.8+;
Maven 3.2.x或以上版本;
RocketMQ集群环境;
项目下载
$ git clone https://github.com/apache/rocketmq-externals项目构建
$ cd rocketmq-externals/rocketmq-connect
$ mvn clean install -Dmaven.test.skip=true项目配置
修改配置文件connect.conf
$ cd rocketmq-connect/rocketmq-connect-runtime/target/distribution/conf
$ vim connect.conf创建Topic
进入到rocketmq的包中
使用
mqadmin在broker集群上创建对应的Topic
可以看到
updateTopic的参数设置,并用此创建
这里 -b 需要broker的地址,需要换成自己的集群地址
更多配置参数,请参考文档
项目运行
运行脚本
看到如下信息表示成功
查看日志
查看日志文件
可以看到对应的日志
Last updated
Was this helpful?