关于建设公司网站的议题,网站后台改变图片尺寸,各大网站大全,做cg的网站在flinkCDC源数据配置中#xff0c;只对表中的部分字段关注#xff0c;通过监控部分字段进行数据更新或者不更新#xff0c;对数据进行同步。主要通过以下两个参数#xff1a;
column.exclude.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表#xff0c;与…在flinkCDC源数据配置中只对表中的部分字段关注通过监控部分字段进行数据更新或者不更新对数据进行同步。主要通过以下两个参数
column.exclude.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表与列的完全限定名称匹配以从更改事件记录值中排除。列的完全限定名称的格式为databaseName。表名。列名。
column.include.list
默认: 空字符串
一个可选的、以逗号分隔的正则表达式列表与列的完全限定名称匹配以包含在更改事件记录值中。列的完全限定名称的格式为databaseName。表名。列名。
单表可以只写列名如果是多表、多库必须要databaseName.表名.列名这种方式的配置。 REATE TABLE IF NOT EXISTS test_source ( testid varchar ( 32 ), name int, addre varchar ( 100 ), stat int, updateTime TIMESTAMP, PRIMARY KEY ( testid ) NOT ENFORCED ) WITH ( connector mysql-cdc, hostname *******, port **, username ***, password********, database-name dbname, scan.startup.mode initial, debezium.skipped.operationsd,c, table-name tablename, debezium.column.include.listname,addre );
