第 9 章 SQL Server 的 Debezium 连接器
Debezium SQL Server 连接器捕获 SQL Server 数据库模式中发生的行级更改。
有关与此连接器兼容的 SQL Server 版本的详情，请查看 Debezium 支持的配置 页面。
有关 Debezium SQL Server 连接器及其使用的详情，请查看以下主题：
- 第 9.1 节 “Debezium SQL Server 连接器概述”
- 第 9.2 节 “Debezium SQL Server 连接器如何工作”
- 第 9.2.10 节 “Debezium SQL Server 连接器数据更改事件的描述”
- 第 9.2.12 节 “Debezium SQL Server 连接器如何映射数据类型”
- 第 9.3 节 “设置 SQL Server 以运行 Debezium 连接器”
- 第 9.4 节 “部署 Debezium SQL Server 连接器”
- 第 9.5 节 “在 schema 更改后刷新捕获表”
- 第 9.6 节 “监控 Debezium SQL Server 连接器性能”
Debezium SQL Server 连接器第一次连接到 SQL Server 数据库或集群时，它会获取数据库中模式的一致性快照。初始快照完成后，连接器会持续捕获 INSERT、UPDATE 或 DELETE 操作的行级更改，这些操作提交到为 CDC 启用的 SQL Server 数据库。连接器为每个数据更改操作生成事件，并将其流传输到 Kafka 主题。连接器将表的所有事件流传输到专用 Kafka 主题。然后，应用程序和服务可以使用该主题中的数据更改事件记录。
9.1. Debezium SQL Server 连接器概述
Debezium SQL Server 连接器基于 SQL Server 2016 Service Pack 1 (SP1)及更高版本中 提供的 更改数据捕获 功能。SQL Server 捕获进程监控指定的数据库和表，并将更改存储在特定创建的 change tables 中。
要启用 Debezium SQL Server 连接器捕获数据库操作的更改事件记录，您必须首先在 SQL Server 数据库上启用更改数据捕获。在要捕获的每个表上必须同时启用 CDC。在源数据库上设置 CDC 后，连接器可以捕获数据库中发生的行级 INSERT、UPDATE、和 DELETE 操作。连接器将每个源表的事件记录写入 Kafka 主题，特别是专用于该表。每个捕获的表都有一个主题。客户端应用程序读取它们遵循的数据库表的 Kafka 主题，并可以响应它们从这些主题中使用的行级事件。
当连接器第一次连接到 SQL Server 数据库或集群时，它会为其配置的所有表获取一致的模式快照，并将其配置为捕获更改，并将这个状态流传输到 Kafka。快照完成后，连接器会持续捕获后续的行级更改。通过首先建立所有数据的一致性视图，连接器可以继续读取，而不会丢失快照发生时所做的任何更改。
Debezium SQL Server 连接器可以接受故障。当连接器读取更改并生成事件时，它会定期记录数据库日志中事件的位置(LSN / Log Sequence Number)。如果连接器因任何原因（包括通信失败、网络问题或崩溃）停止，重启连接器会从它读取的最后一个点恢复 SQL Server CDC 表。
偏移定期提交。它们不会在发生更改事件时提交。因此，在中断后，可能会生成重复的事件。
容错也适用于快照。也就是说，如果连接器在快照过程中停止，连接器会在重启时启动新快照。
