RocketMQ Runtime

快速构建并使用RocketMQ Runtime

RocketMQ Runtime 快速开始

环境依赖

  1. 64bit JDK 1.8+;

  2. Maven 3.2.x或以上版本;

  3. 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 的参数设置,并用此创建

更多配置参数,请参考文档

项目运行

运行前请确认

  1. Nameserv 已经启动

  2. Broker 已启动

运行脚本

看到如下信息表示成功

查看日志

查看日志文件

可以看到对应的日志

Last updated

Was this helpful?