【发布时间】:2022-01-06 06:30:39
【问题描述】:
我们有一个 Always On SQL Server 实例。我想使用 Debezium 跟踪某些表上的 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.$1",
"database.applicationIntent": "ReadOnly"
}
}
这里的问题是,debezium 成功地将表快照到相关的 Kafka 主题,但在快照后不跟踪 cdc 事件。有人知道吗?
【问题讨论】:
标签: sql-server apache-kafka debezium