成功快照 Always On SQL 服务器后,Debezium 未跟踪 CDC

Debezium not tracking CDC after successful snapshot of Always On SQL Server

我们有一个 Always On SQL 服务器实例。我想使用 Debezium 跟踪某些 table 上的 CDC 事件。按照 debezium 网站上的官方教程,我注册了一个具有以下属性的连接器:

{
    "name": "debezium-alwayson-connector",
    "config": {
        "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
        "database.hostname": "<ip-address>",
        "database.port": "1433",
        "database.user": "<username>",
        "database.password": "<password>",
        "database.dbname": "<db_name>",
        "database.server.name": "<server_name>",
        "table.include.list": "dbo.<table_name>",
        "database.history.kafka.bootstrap.servers": "kafka:9092",
        "database.history.kafka.topic": "dbhistory.alwayson",
        "tombstones.on.delete":"false",
        "transforms":"Reroute",
        "transforms.Reroute.type":"io.debezium.transforms.ByLogicalTableRouter",
        "transforms.Reroute.topic.regex":"(.*)",
        "transforms.Reroute.topic.replacement":"cdc_landing.",
        "database.applicationIntent": "ReadOnly"
    }
}

这里的问题是,debezium 成功快照 table 到相关的 Kafka 主题,但在快照后不跟踪 cdc 事件。有人知道吗?

's answer, we found out that we didn't have the privileges to execute that SQL command. For those who are having this kind of problem, please check that you have the correct privileges. Important Note: In debezium's source code 之后表明未使用引用的 SQL 命令,但由于我们使用的是 1.7 版,debezium 试图执行该命令但失败了。