You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
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