我们有一个始终在线的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事件。有人知道吗?
按照Dude0001的回答,我们发现我们没有执行该SQL命令的权限。对于有此类问题的人,请检查您是否拥有正确的权限。重要提示:在debezium的源代码中,声明没有使用引用的SQL命令,但由于我们使用的是1.7版,debezium试图执行该命令,但失败了。
根据Debezium SQL Server连接器文档,初始快照仅在连接器首次运行时激发。然而,如果我删除连接器并创建一个新的但具有相同的名称,初始快照也不能工作。这是故意的还是已知的问题?有什么需要帮忙的吗
我正在使用MongoDB atlas和一个分片副本集集群,以及文档中描述的Debezium MongoDB连接器。 这是我当前配置的样子(运行独立设置): 我可以在Kafka主题中接收CDC事件,但文档中描述的初始快照从未制作过。我尝试了另一种导致创建和使用完全不同的主题集,但结果相同。 MongoDB oplog有大约200万行,kafka主题总共几乎没有几千条消息。 进一步挖掘时,连接器似乎记
我需要在。我发现了这里提到的一种方法。它表明: 快照完成后,使用更新的白名单启动原始连接器 但是如何才能发现快照是否完整呢?
首次启动后,Debezium将对已经存在的数据进行初始数据快照。 假设我有两个表-和。表B对具有FK约束。根据Debezium的默认方法--Debezium将为表和中的数据创建两个单独的Kafka主题。 根据我的理解,我很有可能尝试在新表中创建记录,而适当的记录将不存在于适当的新表中。这样我就会遇到约束冲突错误。 例如-我是否可以使用Debezium主题路由https://Debezium.io/
我正在使用Debezium connector for MySQL和Kakfa。因此,我的模式更改和数据更改进入Kafka主题。 我想看看下面的行为是否可以在没有人工干预的情况下实现。 我希望只有一个表作为快照。然后,我希望多个表被监控,以进行CDC。 https://debezium.io/documentation/reference/stable/connectors/mysql.html似
第一步,登录niushop商城后台,在设置菜单栏下找到配送管理-->物流配送->物流跟踪设置,提供快递100免费版和企业版两个接口,在后台看见,免费版只需要APPKEY一个参数,企业版需要APPKEY和CUSTOMER两个参数。 如何申请这两个接口?获取这些参数? 第二步,登录快递100官网,注册账号,选择快递接口,进行接口申请。 根据个人需要选择,免费或者企业的接口,填写基本信息,提交。 注意: