注意事项
仅支持内核版本19.2.0及以上版本的数据库实例开启 Binlog 日志。
内核版本低于20.0.0的数据库实例开启 Binlog 日志后将自动禁用
CREATE TABLE ... AS SELECT ...语法,如需恢复,需联系技术支持关闭同步功能并重启实例。内核版本低于21.0.0的数据库实例不支持生成 VIEW(视图)操作的 Binlog 日志。
暂不支持生成 FUNCTION(函数)、PROCEDURE(存储过程)、TRIGGER(触发器)操作的 Binlog 日志。
第一步:开启 TDSQL Boundless 实例的 Binlog
1. 按照 管理 Binlog 中开启 Binlog 的步骤,开启实例的 Binlog 日志。
开通成功后,您将获取 Binlog CDC 的 IP 与端口,请妥善保管,后续将用于创建数据订阅任务。
2. 创建用于数据订阅的用户,并赋予
REPLICATION CLIENT、REPLICATION SLAVE、PROCESS 和全部对象的 SELECT权限。2.1 登录 控制台,在实例列表中,选择已开通 Binlog 的实例 ID。
2.2 进入账号管理页面,单击创建账号,创建用于数据同步的用户。
2.3 在账号所在行,单击操作列修改权限,赋予
REPLICATION CLIENT、REPLICATION SLAVE、PROCESS 和全部对象的 SELECT权限。
第二步:网络准备
使用 DTS 进行数据库的订阅,需要分别将源/目标数据库所在的网络与 DTS 所属的腾讯云网络进行打通,以便 DTS 可以连通源/目标数据库。
第三步:使用 DTS 创建数据订阅任务
1. 登录 DTS 控制台,在左侧导航选择数据订阅页,单击新建数据订阅。
2. 在新建数据订阅页,选择相应配置,单击立即购买。
配置项 | 说明 |
服务类型 | 数据订阅 |
数据库 | 选择 TDSQL Boundless。 |
地域 | 地域需与源数据库实例的地域保持一致。 |
版本 | 选择 Kafka 版,支持通过 Kafka 客户端直接消费。 |
订阅实例名称 | 编辑当前数据订阅实例的名称。 |

3. 购买成功后,返回数据订阅列表,单击操作列的配置订阅,对刚购买的订阅进行配置,配置完成后才可以使用。

4. 配置数据订阅页面,选择源数据库相应配置,完成后单击测试连通性,测试通过后单击保存并下一步。

配置项 | 说明 |
云数据库实例 | 选择在第一步中已开通 Binlog 的实例。 |
账号/密码 | 在第一步中已创建的具有 REPLICATION CLIENT、REPLICATION SLAVE、PROCESS 和全部对象的 SELECT权限的账号。 |
5. 在订阅类型和对象选择页面,选择订阅类型,单击保存并下一步。

配置项 | 说明 |
订阅类型 | 数据更新:订阅源库全部对象的数据更新,包括数据 INSERT、UPDATE、DELETE 操作。结构更新:订阅源库全部对象的结构创建、修改和删除。 全实例:订阅源库全部对象的数据更新和结构更新。 |
订阅数据格式 | 支持 ProtoBuf、Avro 和 JSON 三种格式。 ProtoBuf 和 Avro 采用二进制格式,消费效率更高,JSON 采用轻量级的文本格式,更加简单易用。 |
Topic 分区数量 | 设置数据投递到内置 Kafka 中 Topic 的分区数量,增加分区数量可提高数据写入和消费的速度。单分区可以保障消息的顺序,多分区无法保障消息顺序,如果您对消费消息的顺序有严格要求,请选择分区数量为1。 |
Topic 分区策略 | Topic 分区数量为4或8时,需配置 Topic 分区策略。 按表名分区:将相同表名的数据写入同一个分区中。 表名 + 主键分区:将相同主键的数据写入同一个分区。适用于热点数据的表,可以将热表数据分散到不同分区中,提升并发消费效率。 |
使用自定义分区策略 | Topic 分区数量为4或8时,支持配置自定义分区策略。 |
6. 在预校验页面,预校验任务预计会运行2分钟 - 3分钟,预校验通过后,单击启动完成数据订阅任务配置。

7. 单击启动后,订阅任务会进行初始化,预计会运行3分钟 - 4分钟,初始化成功后进入运行中状态。