云消息队列 RocketMQ 版Global Replicator支持消费进度同步功能,本文为您介绍消费进度同步的操作步骤。
单向同步任务
注意事项
消费进度同步功能开启后,如果选择自动更新消费进度,则每10秒会对实例间所有Topic映射关系下的同名Group进行自动消费进度同步。
开启自动更新消费进度后,如果目标集群对应的Group处于在线状态,则不会进行消费进度的同步;而手动一键同步时,无论Group是否在线,都会进行消费进度的同步。
源集群和目标集群Topic下的Group需要保持一致,即仅会同步源集群和目标集群Topic下相同Group的消费进度。
消费进度的同步存在分钟级的时间差,可能会导致消息的重复,业务上请务必做好幂等性处理。
操作步骤
在顶部菜单栏选择地域,如华东1(杭州)。
在左侧导航栏,单击Global Replicator,在任务列表中,单击目标任务名称。
在任务基本信息页面,单击左侧导航栏的消费进度同步。
打开消费进度同步功能开关。
选择自动或者手动同步。
自动同步:
打开自动更新消费进度开关即可实现自动同步。首次打开消费进度同步功能开关时,自动更新消费进度默认处于开启状态。
手动同步:
关闭自动更新消费进度开关后,单击一键同步,在一键同步对话框中单击确定,即可实现手动同步。
双向同步任务
注意事项
消费进度同步功能开启后,不会自动同步消费进度,您可以在业务异常场景下手动触发同步消费进度,减少重复消费的消息量。
如果源集群和目标集群均处于消费状态,当源集群的消费进度小于目标集群时,手动一键同步才会将目标集群的消费进度更新至源集群,否则不会进行消费进度的同步。
源集群和目标集群Topic下的Group需要保持一致,即仅会同步源集群和目标集群Topic下相同Group的消费进度。
消费进度的同步存在分钟级的时间差,可能会导致消息的重复,业务上请务必做好幂等性处理。
操作步骤
在顶部菜单栏选择地域,如华东1(杭州)。
在左侧导航栏,单击Global Replicator,在任务列表中,单击目标任务名称。
在任务基本信息页面,单击左侧导航栏的消费进度同步。
打开消费进度同步功能开关。
如需切换同步方向,单击切换同步方向,在切换同步方向对话框中单击确定。
单击一键同步,在一键同步对话框中单击确定。