我删除的数据无法在doris同步删除,只能做新增,doris版本为3.1.4
我删除的数据无法在doris同步删除,只能做新增,doris版本为3.1.4
routineload 不能直接解析 debezium 的json,routineload 只能用一些表达式进行导入过滤。当前最主流的方式就是需要加一层flink 进行解析,然后通过 doris flink connector的方式导入到Doris中。或者就是使用Doris 的streaming job + Doris 的merge into 语法直接入。第一种比较主流,第二种需要手动编写merge into 语法,目前灵活性差一些。