操作流程

說明

1. 準備工作概覽

在使用DTS執行數據訂閱前，您需要對源數據庫做一些準備工作，以滿足DTS對環境的要求。

2. 配置訂閱任務

您只需在控制臺上進行簡單操作，即可完成數據訂閱的配置。

3. 管理訂閱通道

• 新增消費組

  配置完數據訂閱通道后，您需要新增一個消費組供客戶端進行數據消費。您也可以通過創建多個消費組，對同一個數據源的數據進行重復消費，從而降低數據訂閱的使用成本，提升數據消費速度。

• 可選：管理消費組

  對數據訂閱通道的消費組進行管理（例如修改消費組密碼、刪除消費組）。

• 可選：修改訂閱對象

  在數據訂閱的過程中，您可以修改訂閱對象。

4. 消費訂閱數據

根據消費客戶端和數據庫的類型，選擇訂閱數據的消費方式：

• 使用SDK示例代碼消費訂閱數據

• 使用SDK示例代碼消費PolarDB-X 1.0訂閱數據

• 使用flink-dts-connector消費訂閱數據

• 使用Kafka客戶端消費訂閱數據

5. 結束數據訂閱

釋放實例即可結束數據訂閱。

• 按量付費：詳情請參見釋放按量付費實例。

• 包年包月：詳情請參見退訂包年包月實例。

  說明

  您也可以通過初始化數據訂閱通道（重新配置數據訂閱）來停止數據訂閱，詳情請參見重置DTS實例。