Debezium仅在启动时报告更改事件



我正在使用Debezium Spring Boot starter及其供应商:

org.springframework.boot:spring-boot-starter-parent:2.4.10
org.springframework.cloud.fn:cdc-debezium-boot-starter:1.0.3
org.springframework.cloud.fn:cdc-debezium-supplier:1.0.3

我已经配置了SQLServer,在数据库上启用CDC,也在表上启用CDC,以便按照Debezium文档进行捕获:

-- enable CDC on database
USE my_db;
exec sys.sp_cdc_enable_db;
-- add filegroup to store CDC data
ALTER DATABASE my_db;
ADD FILEGROUP CDC_DATA; 
-- enable CDC on ACTIONS table
USE my_db;
EXEC sys.sp_cdc_enable_table
@source_schema=N'dbo',
@source_name=N'ACTIONS',
@role_name = NULL,
@filegroup_name=N'CDC_DATA',
@supports_net_changes=0
-- check if it is enabled
EXEC sys.sp_cdc_help_change_data_capture;

它返回:

captured_column_list[ACTIONID][ACTIONID], [TMSTAMP], [apu], [OSUSER],[意见],[状态]

我遇到类似的问题工作但新的更新快照不流。我把问题缩小到FileGroup。

试着注释@filegroup_name=N' cdc_data ',看看是否有帮助。

我认为这是该连接器的一些缺陷,尽管官方使用filegroup debezium教程。https://debezium.io/documentation/reference/stable/connectors/sqlserver.html _enabling_cdc_on_a_sql_server_table

最新更新