详细见官方中文网站介绍及搭建：

https://rocketmq-1.gitbook.io/rocketmq-connector/

主要搭建以下两个模块就可以：

RocketMQ Connect

简单理解RocketMQ Connect就是借RocketMQ从其他系统获取数据发送到RocketMQ，然后从RocketMQ消费消息写入到其他系统。主要由 Source Connector，Sink Connector，Runtime 组成。

Source Connector 负责从其它系统获取数据，通过Producer发送到到RocketMQ。

Sink Connector负 责从Producer中消费消息，将数据写入到另外的系统

Runtime 是Source ，Sink connector的运行时环境，负责加载Connector，提供RESTful接口，启动Connector任务，集群节点之间服务发现，配置同步，消费进度保存，故障转移，负载均衡等能力。

RocketMQ Console

RocketMQ Console是RocketMQ 提供的可视化管理工具，方便可视化的操作。包含了多个功能

• 运维

• 驾驶舱

• 集群

• 主题

• 消费者

• 生产者

• 消息

• 消息轨迹

• connector