Debezium连接SQL Server生产库CDC无法同步数据至Kafka

sp_cdc_help_change_data_capture 生产环境返回空、测试环境正常，核心原因是生产环境同步账号缺少CDC系统对象的访问权限——public+db_datareader角色默认仅授予业务用户表的读取权限，不会自动开通CDC相关系统表、存储过程的访问权，测试环境通常因为权限管控宽松、提前做过授权所以能正常运行。

第一步：先确认生产库CDC本身配置正常 #

先用sysadmin权限账号执行以下查询，排除CDC本身没开全的问题：

-- 验证库级CDC状态，返回1代表已正常开启
SELECT name, is_cdc_enabled FROM sys.databases WHERE name = '你的生产库名';

-- 验证待同步表的CDC状态，对应表的is_tracked_by_cdc字段值为1才代表已开启表级捕获
SELECT name, is_tracked_by_cdc FROM sys.tables;

如果查询结果不符合预期，先补全CDC开启操作：

• 库级未开：执行EXEC sys.sp_cdc_enable_db;
• 表级未开：针对待同步表执行对应的sp_cdc_enable_table存储过程开启捕获

第二步：给同步账号补CDC必需权限 #

如果CDC本身配置正常，直接给同步账号授予CDC最小访问权限即可，不需要给过高的db_owner权限：

1. 把同步账号加入库内置的cdc_reader角色，这个角色默认拥有所有CDC捕获对象的读权限和相关存储过程的执行权限：

   USE 你的生产库名;
   ALTER ROLE cdc_reader ADD MEMBER 你的Debezium同步账号名;
   

2. 如果是低版本SQL Server没有内置cdc_reader角色，手动执行以下授权语句：

   -- 授予CDC架构下所有表的查询权限
   GRANT SELECT ON SCHEMA :: cdc TO 你的Debezium同步账号名;
   -- 授予CDC相关系统函数、存储过程的执行权限
   GRANT EXECUTE ON OBJECT::sys.sp_cdc_help_change_data_capture TO 你的Debezium同步账号名;
   GRANT EXECUTE ON OBJECT::sys.fn_cdc_get_max_lsn TO 你的Debezium同步账号名;
   GRANT EXECUTE ON OBJECT::sys.fn_cdc_get_min_lsn TO 你的Debezium同步账号名;
   GRANT EXECUTE ON OBJECT::sys.fn_cdc_map_lsn_to_time TO 你的Debezium同步账号名;
   

授权完成后，切回同步账号重新执行EXEC sp_cdc_help_change_data_capture，能正常返回所有CDC表配置就代表权限打通。

第三步：排查生产环境特有阻断项 #

如果授权完成后还是不同步，检查几个生产环境常见的特殊配置：

• 若生产部署了Always On高可用组，确认Debezium连接的是AG监听器，且当前主副本上的CDC捕获作业处于正常运行状态，可通过EXEC sp_cdc_help_jobs;查看作业状态，捕获作业需为enabled状态且无近期报错。
• 确认SQL Server Agent服务处于启动状态（2017之前版本的CDC完全依赖Agent跑捕获任务，高版本也默认依赖Agent调度）。
• 检查生产库是否开启了AUTO_CLOSE选项，该选项开启会导致CDC作业异常中断，需手动关闭。

以上配置确认完成后，重启Debezium的SQL Server连接器任务，即可正常在Kafka对应主题收到生产库的变更数据。

内容的提问来源于stack exchange，提问作者Mohsen S. Beigi