TDMQ Pulsar 专业集群基于 GEO Replication 方案,实现跨地域的集群复制,可以支持用户用于异地容灾、数据归档和异地消费等场景。

上海地域的 Pulsar 集群中运行 Replicator 组件,该组件中会启动 Producer-R,绑定了北京地域对端集群的 Topic1,将消息数据用生产者的方式发送到北京机房。
说明:
上海集群中生产的消息首先在本地集群中持久化,然后再被异步转发到北京集群。
上海集群 Replicator 中的 Producer-R ,与该集群的客户端 Producer1 没有任何关系。 Producer-R 配置的集群地址是北京集群地址。
复制流程描述
1. Producer1 生产消息到上海集群 Topic1;
2. 上海集群把消息持久化到 BookKeeper;
3. BookKeeper 返回成功后把消息推给 Replicator 的 Cursor;
4. Replicator 的 Cursor 通过 Producer-R 把消息发给北京集群 Topic1;
5. 北京集群 Topic1 写入 BookKeeper 成功后给上海集群 Replicator 的 Cursor 回复 ACK,上海机房 Cursor 收到 ACK 后通过 Producer-R 推送下一条消息。
操作指南
1. 登录 TDMQ Pulsar 版控制台
2. 在目标复制地域创建一个专业集群,在集群购买界面,需要开启跨地域复制开关,并选择数据源集群;

3. 在控制台的左侧导航栏选择跨地域复制,单击新建链路,配置集群的消息数据同步链路:
复制链路名称:为同步链路定义一个名字,不能为空,支持数字字母以及符号 “-_=:.”,长度不超过128个字符。
链路类型:选择消息级。
源集群选择:选择要进行复制的数据源 Pulsar 集群。
目标集群选择:在不同地域选择创建好的目标集群,此处仅会显示「集群 ID」相同的集群。
复制级别:支持集群级、命名空间和 Topic 三个级别。
集群级,适用于集群级的复制。
命名空间级,适用于两地集群日常都是活跃的,不同的命名空间分布在不同地域。
Topic 级,跨地域复制的最小粒度。
协议条款:勾选我已阅读并同意《消息队列 TDMQ 服务条款》
4. 单击保存,并完成支付。
5. 创建完成后,消息级的复制任务会进入到监控界面,您可以查阅复制任务的实时复制速率、复制消息堆积等数据。