旧版订阅迁移至新版订阅

注意事项

• 由于旧版订阅和新版订阅使用的架构和实现方式不同，所以您需要重新创建新版订阅实例进行消费。
• 此操作需要您释放旧版订阅实例，实例释放后无法找回，请确保新版订阅实例可以正常消费到数据后再释放旧版订阅实例。

操作步骤

1. 创建新版订阅实例，详情请参见订阅方案概览中的相关配置文档。
2. 消费订阅数据，详情请参见消费订阅数据。

   表 1. 旧版订阅和新版订阅实例主要差异对比

   对比项	旧版订阅	新版订阅
   消费方式	使用AccessKey（AK）信息进行消费。	创建消费组进行消费，详情请参见新增消费组。
   消费时间点的管理	整个订阅实例使用一份位点数据。 可以在DTS控制台修改消费的时间，详情请参见修改消费时间点。	每个消费组单独使用一份位点数据。 新版订阅的位点管理比较灵活和多样，SDK客户端重启时，SUBSCRIBE模式使用Server端保存的位点，但是不可以修改；ASSIGN模式默认使用每次传入的位点信息。详情请参见保存和查询消费位点。
   客户端使用的SDK	必须使用DTS提供的旧版SDK，详情请参见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客户交流钉钉群（群号：3685018060），进行咨询。