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此功能尚不成熟还需要后续版本优化
启动元数据同步模板
Sink Connector
Replicator没有SinkConnector
Last updated