注意事項

• 由于舊版訂閱和新版訂閱使用的架構和實現方式不同，所以您需要重新創建新版訂閱實例進行消費。

• 此操作需要您釋放舊版訂閱實例，實例釋放后無法找回，請確保新版訂閱實例可以正常消費到數據后再釋放舊版訂閱實例。

操作步驟

1. 創建新版訂閱實例，詳情請參見訂閱方案概覽中的相關配置文檔。

2. 消費訂閱數據，詳情請參見消費訂閱數據。

   表 1. 舊版訂閱和新版訂閱實例主要差異對比

   對比項	舊版訂閱	新版訂閱
   消費方式	使用AccessKey（AK）信息進行消費。	創建消費組進行消費，詳情請參見新增消費組。
   消費時間點的管理	整個訂閱實例使用一份位點數據。 可以在DTS控制臺修改消費的時間。	每個消費組單獨使用一份位點數據。 新版訂閱的位點管理比較靈活和多樣，SDK客戶端重啟時，SUBSCRIBE模式使用Server端保存的位點，但是不可以修改；ASSIGN模式默認使用每次傳入的位點信息。詳情請參見保存和查詢消費位點。
   客戶端使用的SDK	必須使用DTS提供的舊版SDK。	使用DTS提供的新版的訂閱SDK消費訂閱數據（推薦），詳情請參見使用SDK示例代碼消費訂閱數據。 使用Flink客戶端消費訂閱數據，詳情請參見使用flink-dts-connector消費訂閱數據。 使用原生的Kafka客戶端消費訂閱數據，詳情請參見使用Kafka客戶端消費訂閱數據。
   訂閱消息的格式	舊版訂閱的格式。	新版的訂閱SDK：DefaultUserRecord。 Flink客戶端：DataStream API、Table API和SQL。 Kafka客戶端：Avro。
   問題排查	無	根據新版SDK的報錯排查新版訂閱任務問題：問題排查 使用DTS定制工具包排查新版訂閱任務問題：排查訂閱任務問題

3. 確保新版訂閱實例可以正常消費到指定位點的數據后，釋放舊版訂閱實例，詳情請參見釋放DTS實例。

聯系我們

若您對此功能有疑問，您可以通過釘釘（釘釘通訊客戶端下載地址）進入到DTS客戶交流釘釘群（群號：68325004196或68640008972），進行咨詢。