我正在使用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;
它返回:
我遇到类似的问题工作但新的更新快照不流。我把问题缩小到FileGroup。
试着注释@filegroup_name=N' cdc_data ',看看是否有帮助。
我认为这是该连接器的一些缺陷,尽管官方使用filegroup debezium教程。https://debezium.io/documentation/reference/stable/connectors/sqlserver.html _enabling_cdc_on_a_sql_server_table