我们在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事件。有人知道吗?
https://stackoverflow.com/questions/70154163
复制相似问题