消息队列 RocketMQ 版 主题间消息复制

TDMQ RocketMQ 支持客户在两个集群之间同步消息:同个地域或不同地域间;4.x 集群之间,5.x 集群之间,4.x 到 5.x 集群的复制(反向同步,即消息从5.x集群复制到4.x集群暂不支持),可以以按照 Topic 维度,把集群 A 的某个 Topic 的消息复制到集群 B 的某个 Topic。在进行某个 Topic 的消息复制时,RocketMQ 支持按照特定的条件进行过滤(例如 Tag 或者 SQL。

相关产品
消息队列 RocketMQ 版 产品页,含版本规格、价格与购买入口。

一、计费规则

消息跨集群复制功能当前免费;在开始收费前,腾讯云会提前一个月多次通过站内信、短信和邮件等形式通知客户。

二、创建任务

进入消息队列 RocketMQ 版控制台,单击左侧导航栏跨集群复制 > 新建任务, 按照要求填写以下字段:

·任务类型:选择 Topic 跨集群复制。

·任务名称:200字符以内,只能包含 中文、数字、字母、“-”和“_”;

·源 Topic:通过下拉依次选择地域、集群、命名空间和 Topic,如果找不到需要的集群或 Topic 可以在集群列表页进行新建。

·目标 Topic:通过下拉依次选择地域、集群、命名空间和 Topic,如果找不到需要的集群或 Topic 可以在集群列表页进行新建。

·复制任务使用的角色:选择进行复制任务时使用的角色;即复制时将使用对应角色的 AK, SK 进行消息的复制,因此确保对应的角色有源或者目标 Topic 的对应权限,更多权限的设置可以参考配置资源权限。跨云进行复制时,需要手动填写对应其他云的 AK, SK,同时保证使用 AK, SK 有对应的权限。

·过滤类型:支持 TAG 过滤和 SQL 过滤两个方式。

·复制起始位置:支持从最新的位点开始复制或者指定时间点开始复制。

·是否立即开启任务:如果打开开关,在任务创建完成后就按照当前任务的配置进行复制。

单击创建任务后,会跳转到任务列表页,在任务初始化后即创建完成。

你创建的复制任务是单向的,即如果你创建一个 Topic A 到 Topic B 的复制任务,Topic A 的消息会自动复制到 Topic B;如果你需要双向的复制任务,你需要再次新建一个从 Topic B 到 Topic A 的复制任务。

三、复制任务

为了方便消息复制任务的创建,你也可以通过复制已有任务的配置快速创建新的任务。

进入消息队列 RocketMQ 版控制台,单击左侧导航栏跨集群复制,选择已创建的任务,单击操作列的新建类似,创建任务的页面会自动填充复制任务的相同参数,只需要简单修改后即可创建新的任务(目前控制台不得创建完全相同配置的任务)。

四、查看任务详情

在任务创建完成后,你可以在任务的列表页看到新增的复制任务,同时可以快速查看任务的状态。单击操作列的启动/暂停可以快速的开启和暂停任务。

运行中的任务不能修改配置信息,如果要修改复制任务的配置,请先暂停任务后,单击操作栏的编辑,或者进入任务详情页,单击“基本信息”右上角的编辑,修改任务的信息。

你可以单击任务名称,进入任务详情页查看任务的详细配置,例如过滤规则和起始时间等等。 在监控部分,你可以查看当前消息复制任务的实时监控,例如源消息消费总条数、消息复制失败条数、消息同步延迟等。

五、异常处理

正常情况下,状态栏会展示 “运行中” 或者 “已暂停” 的状态;如果状态为 “启动失败”,你需要检查任务运行状态和任务详细配置是否正确,例如 SQL 表达式是否正确等;鼠标悬浮在失败状态上会有具体的失败原因。

如果任务状态失败,你可以单击操作栏的编辑,或者进入任务详情页,单击“基本信息”右上角的编辑,重新更正任务的信息。

赞 (0)
上一篇 4天前
下一篇 4天前