ApsaraMQ for RocketMQGlobal Replicator支援消費進度同步功能,本文為您介紹消費進度同步的操作步驟。
單向同步任務
注意事項
消費進度同步功能開啟後,如果選擇自動更新消費進度,則每10秒會對執行個體間所有Topic映射關係下的同名Group進行自動消費進度同步。
開啟自動更新消費進度後,如果目的地組群對應的Group處於線上狀態,則不會進行消費進度的同步;而手動一鍵同步時,無論Group是否線上,都會進行消費進度的同步。
源叢集和目的地組群Topic下的Group需要保持一致,即僅會同步源叢集和目的地組群Topic下相同Group的消費進度。
消費進度的同步存在分鐘級的時間差,可能會導致訊息的重複,業務上請務必做好等冪性處理。
操作步驟
在頂部功能表列選擇地區,如華東1(杭州)。
在左側導覽列,單擊Global Replicator,在工作清單中,單擊目標任務名稱。
在任務基本資料頁面,單擊左側導覽列的消費進度同步。
開啟消費進度同步功能開關。
選擇自動或者手動同步。
自動同步:
開啟自動更新消費進度開關即可實現自動同步。首次開啟消費進度同步功能開關時,自動更新消費進度預設處於開啟狀態。
手動同步:
關閉自動更新消費進度開關後,單擊一鍵同步,在一鍵同步對話方塊中單擊確定,即可實現手動同步。
雙向同步任務
注意事項
消費進度同步功能開啟後,不會自動同步消費進度,您可以在業務異常情境下手動觸發同步消費進度,減少重複消費的訊息量。
如果源叢集和目的地組群均處於消費狀態,當源叢集的消費進度小於目的地組群時,手動一鍵同步才會將目的地組群的消費進度更新至源叢集,否則不會進行消費進度的同步。
源叢集和目的地組群Topic下的Group需要保持一致,即僅會同步源叢集和目的地組群Topic下相同Group的消費進度。
消費進度的同步存在分鐘級的時間差,可能會導致訊息的重複,業務上請務必做好等冪性處理。
操作步驟
在頂部功能表列選擇地區,如華東1(杭州)。
在左側導覽列,單擊Global Replicator,在工作清單中,單擊目標任務名稱。
在任務基本資料頁面,單擊左側導覽列的消費進度同步。
開啟消費進度同步功能開關。
如需切換同步方向,單擊切換同步方向,在切換同步方向對話方塊中單擊確定。
單擊一鍵同步,在一鍵同步對話方塊中單擊確定。