修改日期 | 修改人 | 备注 |
2020-05-13 18:13:14[当前版本] | 文艺范儿 | 格式调整 |
2020-05-13 18:05:10 | 文艺范儿 | 创建版本 |
详细见官方中文网站介绍及搭建:
https://rocketmq-1.gitbook.io/rocketmq-connector/
简单理解RocketMQ Connect就是借RocketMQ从其他系统获取数据发送到RocketMQ,然后从RocketMQ消费消息写入到其他系统。主要由 Source Connector,Sink Connector,Runtime 组成。
Source Connector 负责从其它系统获取数据,通过Producer发送到到RocketMQ。
Sink Connector负 责从Producer中消费消息,将数据写入到另外的系统
Runtime 是Source ,Sink connector的运行时环境,负责加载Connector,提供RESTful接口,启动Connector任务,集群节点之间服务发现,配置同步,消费进度保存,故障转移,负载均衡等能力。