【发布时间】:2021-06-07 17:25:53
【问题描述】:
我正在尝试使用 SQL Server 数据库让 transaction metadata 与 debezium 1.4.1.Final 一起使用。
它似乎在某种程度上起作用 - dbservername.transaction 主题已创建,当我运行包含事务的存储过程时,会收到 "status":"BEGIN" 事件以及表上的 CDC 数据包主题。
但是,在我再次运行存储过程之前,没有收到 "status":"END" 事件。
很可能是我没有正确关闭存储过程中的事务(无论如何我都不是 MSSQL 专家)...
这是我正在使用的结构:
CREATE PROCEDURE schema.myproc
AS
BEGIN
BEGIN TRANSACTION
...
COMMIT;
END
GO
我需要做什么才能在过程结束时获得END 事件?
【问题讨论】:
-
debezium Github 的主页上说“只有提交的更改可见”:github.com/debezium/debezium这可能是原因吗?
-
我认为这只是指将发布到 Kafka 的唯一事件是已在数据库中提交的更改。事务元数据对于将多个已提交的更改分组到消费者的逻辑集合中很有用。
标签: sql-server debezium