Replicator简介

Replicator的概念，使用场景进行简单介绍

Replicator

Replicator 部署图

Replicator是RocketMQ Connector的别名，用于RocketMQ集群之间的信息同步，Replicator是运行在RocketMQ Runt上的RocketMQ 集群消息同步Connector，其主要实现了Connector的机制,能够同步两个独立的RocketMQ集群之间的消息。

Source Connector

Replicator Connector 包含两种Source Connector：RmqSourceReplicator和RmqMetaReplicator

• RmqSourceReplicator

  • Topic同步

  • 自动创建topic

  • 消息白名单

  • 任务并行度

• RmqMetaReplicator

  • 同步消费消费进度和ConsumerGroup

注：RmqMetaReplicator此功能尚不成熟还需要后续版本优化

• 启动元数据同步模板

http://${runtime-ip}:${runtime-port}/connectors/${rocketmq-replicator-name}
 ?config={
 "connector-class":"org.apache.rocketmq.replicator.RmqMetaReplicator",
 "source-rocketmq":"xxxx:9876",
 "target-rocketmq":"xxxxxxx:9876",
 "replicator-store-topic":"replicatorTopic",
 "offset.sync.topic":"syncTopic",
 "taskDivideStrategy":"0",
 "white-list":"TopicTest,TopicTest2",
 "task-parallelism":"2",
 "source-record-converter":"org.apache.rocketmq.connect.runtime.converter.JsonConverter"
 }

Sink Connector

Replicator没有SinkConnector