问题描述
需求期望记录一张表的数据删除记录,使用mysql cdc来实现。使用 ‘debezium.skipped.operations’=’c,u,t’参数进行过滤后,通过’connector’ = ‘print’为sink在日志可以看到删除记录,但使用’connector’ = ‘jdbc’和’connector’ = ‘mysql’无法将删除记录写入。取消过滤条件后,新增、更改记录均可以正常写入目标表,删除依旧不行。
期望结果
正确将删除记录同步到目标表
已尝试的方法
sink尝试不同connector
cdc不支持将删除记录-D 转为 -I