文档

旧版订阅迁移至新版订阅

更新时间:

DTS旧版数据订阅功能已经下线,新版本控制台不再支持配置旧版订阅任务。为保证您业务的正常运行,您需要手动将旧版订阅实例迁移至新版订阅实例。

注意事项

  • 由于旧版订阅和新版订阅使用的架构和实现方式不同,所以您需要重新创建新版订阅实例进行消费。

  • 此操作需要您释放旧版订阅实例,实例释放后无法找回,请确保新版订阅实例可以正常消费到数据后再释放旧版订阅实例。

操作步骤

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

  2. 消费订阅数据,详情请参见消费订阅数据

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

    对比项

    旧版订阅

    新版订阅

    消费方式

    使用AccessKey(AK)信息进行消费。

    创建消费组进行消费,详情请参见新增消费组

    消费时间点的管理

    • 整个订阅实例使用一份位点数据。

    • 可以在DTS控制台修改消费的时间。

    • 每个消费组单独使用一份位点数据。

    • 新版订阅的位点管理比较灵活和多样,SDK客户端重启时,SUBSCRIBE模式使用Server端保存的位点,但是不可以修改;ASSIGN模式默认使用每次传入的位点信息。详情请参见保存和查询消费位点

    客户端使用的SDK

    必须使用DTS提供的旧版SDK。

    订阅消息的格式

    旧版订阅的格式。

    • 新版的订阅SDK:DefaultUserRecord。

    • Flink客户端:DataStream API、Table API和SQL。

    • Kafka客户端:Avro。

    问题排查

  3. 确保新版订阅实例可以正常消费到指定位点的数据后,释放旧版订阅实例,详情请参见释放DTS实例

联系我们

若您对此功能有疑问,您可以通过钉钉(钉钉通讯客户端下载地址)进入到DTS客户交流钉钉群(群号:68325004196或68640008972),进行咨询。

  • 本页导读 (1)