全部產品
Search
文件中心

Data Transmission Service:資料訂閱SDK容災

更新時間:Jul 06, 2024

為了簡化使用者使用SDK的複雜度,DTS實現了SDK容災機制。這個機制依賴於SDK消費資料時,向DTS中控節點即時彙報消費時間點。本小節簡單介紹如何使用DTS提供的SDK容災機制。

要求

  1. SDK消費代碼中,每消費一個message要調用一次ackAsConsumed,向DTS彙報消費時間點。
  2. 同一個訂閱通道至少啟動2個SDK下遊互為主備。

消費架構圖

SDK容災架構

DTS的一個訂閱通道只能有一個SDK拉取到增量資料。如果在一個訂閱通道中接多個SDK下遊,那麼只有其中一個訂閱SDK能夠接收到增量資料。根據這個原理,可以搭建SDK災備架構。

在上圖這個樣本架構中,對一個訂閱通道中,接了兩個SDK消費下遊,這兩個SDK互為主備,同一個時間內,只有主SDK能訂閱並消費到增量資料。當主SDK異常或是出現網路連接異常時,DTS會自動failover漂移到備SDK上,同時使用最後消費的時間點啟動備SDK。主SDK每消費一條資料,會向DTS控制系統彙報一個ACK,即向控制系統彙報消費時間點。