Debezium连接SQL Server Always On配置与主备切换问题咨询

核心配置误区澄清 #

• worker.properties是Kafka Connect集群的全局运行配置，不需要为SQL Server Always On场景做特殊调整，所有和源库连接相关的参数都定义在Debezium Connector的独立配置中。
• 官方文档提及的database.applicationIntent=ReadOnly仅适用于从只读辅助副本拉取CDC数据的场景，常规需要从主副本捕获事务日志的场景下，该参数配置错误会直接导致连接被路由到只读节点，任务异常。
• database.hostname配置项不支持填写逗号分隔的多节点地址，直接配置多个物理节点地址会被JDBC驱动识别为非法主机名，无法建立连接。

核心参数配置规则 #

• database.server.name：Debezium生成Kafka topic前缀、元数据标识的自定义逻辑名称，和SQL Server物理节点、主备角色完全无关，配置后全程固定即可，比如可设置为业务线标识+数据库用途的组合值，无需随主备切换修改。
• database.hostname：禁止填写单个物理节点地址，必须填写SQL Server Always On可用性组（AG）监听器地址，该地址由DBA提前配置，会自动将连接路由到当前主角色节点，主备切换后地址保持不变。

主备切换无感知配置步骤 #

• 提前协调DBA配置可用性组监听器，确认监听器端口、读写路由策略正常，可通过监听器地址正常连接主库执行读写操作。
• 配置Debezium连接器时，database.hostname填监听器地址，database.port填监听器服务端口，database.applicationIntent固定设为ReadWrite，保证连接始终被路由到可正常读取事务日志的主副本。
• 配置任务重试参数，给主备切换预留足够的重连窗口，避免切换瞬间连接闪断导致任务直接失败。
• 如果有从辅助副本拉取CDC数据降低主库压力的需求，需提前协调DBA开启辅助副本的只读路由、确认辅助副本CDC日志同步正常，再将database.applicationIntent设为ReadOnly，依然通过监听器地址建立连接。

参考配置示例 #

{
  "name": "biz-sqlserver-cdc-task",
  "config": {
    "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
    "database.hostname": "sqlserver-ag-listener.internal", // AG监听器地址
    "database.port": "1433", // 监听器端口
    "database.user": "debezium_cdc",
    "database.password": "your_cdc_password",
    "database.dbname": "target_biz_db",
    "database.server.name": "biz-order-sqlserver", // 固定逻辑名，无需随主备修改
    "database.applicationIntent": "ReadWrite",
    "table.include.list": "dbo.order_,dbo.payment_",
    "database.history.kafka.bootstrap.servers": "kafka-cluster:9092",
    "database.history.kafka.topic": "schema-changelog.biz-order-sqlserver",
    "errors.retry.timeout": "120000",
    "errors.retry.delay.max.ms": "5000"
  }
}

直连物理节点切换后故障原因 #

之前直连初始主节点node1时，主备切换后node1转为只读辅助副本，Debezium连接到该节点后无法正常读取事务日志、执行CDC元数据查询操作，同时没有自动切换到新主节点的路由能力，直接导致复制任务中断。

内容的提问来源于stack exchange，提问作者Akshay