全部產品
Search
文件中心

ApsaraMQ for RocketMQ:消費進度同步

更新時間:Mar 20, 2025

ApsaraMQ for RocketMQGlobal 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. 單擊一鍵同步,在一鍵同步對話方塊中單擊確定