做瞹瞹嗳视频网站在线观看,装饰工程造价,改网站标题,宁阳移动网站制作在flinkCDC源数据配置#xff0c;通过debezium.skipped.operations参数控制#xff0c;配置需要过滤的 oplog 操作。操作包括 c 表示插入#xff0c;u 表示更新#xff0c;d 表示删除。默认情况下#xff0c;不跳过任何操作#xff0c;以逗号分隔。配置多个操作#xff…在flinkCDC源数据配置通过debezium.skipped.operations参数控制配置需要过滤的 oplog 操作。操作包括 c 表示插入u 表示更新d 表示删除。默认情况下不跳过任何操作以逗号分隔。配置多个操作需要英文逗号分隔。
官网说明地址Debezium connector for MySQL :: Debezium Documentation 使用实例如下 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 );
