相关文章推荐

flink1.16.2
flink-connector-sqlserver-cdc-2.4.1
在SQLServer连接器中没有看到scanNewlyAddedTableEnabled,是不支持动态加表吗

SourceFunction SqlserverSource = SqlServerSource.builder()
.hostname(SOURCE_IP)
.port(SOURCE_PORT)
.database(SOURCE_DB)
.tableList("dbo." + String.join(",dbo.", tableList)) // 构造表名字符串
.username(SOURCE_USER)
.password(SOURCE_PWD)
// .scanNewlyAddedTableEnabled(true)
.startupOptions(StartupOptions.initial())
.debeziumProperties(DateToStringConverter.DEFAULT_PROPS)
.deserializer(new JsonDebeziumDeserializationSchema(false, customConverterConfigs))
.build();

2023-09-22 14:20:57,802 INFO io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource [] - CDC is enabled for table Capture instance "dbo_DispatchList" [sourceTableId=UFDATA_889_2018.dbo.DispatchList, changeTableId=UFDATA_889_2018.cdc.dbo_DispatchList_CT, startLsn=00007166:0000087d:0108, changeTableObjectId=1285742103, stopLsn=NULL] but the table is not whitelisted by connector

 
推荐文章