消费进度同步

云消息队列 RocketMQ 版Global Replicator支持消费进度同步功能,本文为您介绍消费进度同步的操作步骤。

单向同步任务

注意事项

  • 消费进度同步功能开启后,如果选择自动更新消费进度,则每10秒会对实例间所有Topic映射关系下的同名Group进行自动消费进度同步。

  • 开启自动更新消费进度后,如果目标集群对应的Group处于在线状态,则不会进行消费进度的同步;而手动一键同步时,无论Group是否在线,都会进行消费进度的同步。

  • 源集群和目标集群Topic下的Group需要保持一致,即仅会同步源集群和目标集群Topic下相同Group的消费进度。

  • 消费进度的同步存在分钟级的时间差,可能会导致消息的重复,业务上请务必做好幂等性处理。

操作步骤

  1. 登录云消息队列 RocketMQ 版控制台

  2. 在顶部菜单栏选择地域,如华东1(杭州)

  3. 在左侧导航栏,单击Global Replicator,在任务列表中,单击目标任务名称。

  4. 任务基本信息页面,单击左侧导航栏的消费进度同步

  5. 打开消费进度同步功能开关。

  6. 选择自动或者手动同步。

    • 自动同步

      打开自动更新消费进度开关即可实现自动同步。首次打开消费进度同步功能开关时,自动更新消费进度默认处于开启状态。

    • 手动同步

      关闭自动更新消费进度开关后,单击一键同步,在一键同步对话框中单击确定,即可实现手动同步。

双向同步任务

注意事项

  • 消费进度同步功能开启后,不会自动同步消费进度,您可以在业务异常场景下手动触发同步消费进度,减少重复消费的消息量。

  • 如果源集群和目标集群均处于消费状态,当源集群的消费进度小于目标集群时,手动一键同步才会将目标集群的消费进度更新至源集群,否则不会进行消费进度的同步。

  • 源集群和目标集群Topic下的Group需要保持一致,即仅会同步源集群和目标集群Topic下相同Group的消费进度。

  • 消费进度的同步存在分钟级的时间差,可能会导致消息的重复,业务上请务必做好幂等性处理。

操作步骤

  1. 登录云消息队列 RocketMQ 版控制台

  2. 在顶部菜单栏选择地域,如华东1(杭州)

  3. 在左侧导航栏,单击Global Replicator,在任务列表中,单击目标任务名称。

  4. 任务基本信息页面,单击左侧导航栏的消费进度同步

  5. 打开消费进度同步功能开关。

  6. 如需切换同步方向,单击切换同步方向,在切换同步方向对话框中单击确定

  7. 单击一键同步,在一键同步对话框中单击确定