舊版訂閱遷移至新版訂閱

注意事項

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

• 此操作需要您釋放舊版訂閱執行個體，執行個體釋放後無法找回，請確保新版訂閱執行個體可以正常消費到資料後再釋放舊版訂閱執行個體。

操作步驟

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執行個體。