数据传输服务 DTS 数据订阅 2.0 升级说明

一、核心架构差异

维度	1.0	2.0
Kafka 架构	地域共享自建 Kafka 集群	云产品 CKafka（单用户隔离）
资源隔离	多用户共享同一集群	每个用户独立 CKafka 实例，完全隔离
高可用	需自行配置	多可用区（AZ）自动部署
接入方式	域名 + NodePort	内网接入点 IP:Port

二、订阅 2.0 的核心优势

1. 更强的资源隔离性：每个用户拥有独立的 CKafka 实例，彻底消除"邻居效应"，避免因其他用户的流量突增影响你的数据订阅性能。

2. 更完善的可观测性：内置丰富的监控指标和告警能力，实时掌握订阅链路健康状态。

3. 更高的可用性：多可用区自动部署，天然具备跨 AZ 容灾能力。

三、唯一需要修改的配置

升级到 2.0 后，你的消费端程序仅需修改一项配置：

配置项	是否需要修改	说明
bootstrap.servers	✔ 需要修改	切换为 2.0 的新 CKafka 内网接入点地址。
topic	✖ 不变	2.0 自动创建与 1.0 同名的 Topic。
group.id	✖ 不变	平台在 2.0 CKafka 上预创建同名消费组。
username	✖ 不变	保持原有用户名不变。
password	✖ 不变	密码同步至 2.0 CKafka 账号。
sasl.mechanism	✖ 不变	保持 SCRAM-SHA-512。

总结：除了 bootstrap.servers 接入地址变更外，你的消费代码、Topic、账号密码、认证方式等全部保持不变，业务改动量极小。

四、当前订阅2.0新购方式说明

1. 登录 DTS 控制台，在左侧导航选择数据订阅，单击新建数据订阅。

2. 在新建数据订阅页，选择相应配置，单击立即购买。

五、需要额外关注的配置差异

订阅 2.0 在配置时有一项新增要求：

注意：需要指定具体的 VPC 和子网 ID。

·配置时：创建/升级订阅任务时，需要指定消费端所在的 VPC ID 和子网 ID。

·使用时：

·同 VPC 访问：相同 VPC 下的所有 CVM 都可以正常访问订阅数据，无需额外配置。

·跨 VPC 访问：如果消费端 CVM 在其他 VPC 中，需要配置云联网来实现跨 VPC 访问。

六、存量订阅1.0任务的升级方案

我们正在陆续推进订阅 1.0 到订阅 2.0 的升级流程产品化，届时将提供控制台一键升级能力，进一步降低升级操作复杂度。

七、产品化升级方案支持

·自动化位点映射，确保消费连续性。

·新老链路并行运行期间的数据一致性保障。

·7 天回滚保护窗口。

·升级前后价格完全一致，无额外费用。

八、升级流程介绍

·升级 2.0 提示

·升级流程1 – 创建影子任务

·升级流程2 – 数据追平

·升级流程3 – 升级切换

·升级流程3 – 消费组级切换步骤

·升级流程3 – 消费组级回滚操作

·升级流程4 – 完成升级

九、注意事项