这个方案怎么说都是可行的,你本身就是ticdc+kafka的模式。就算ticdc上过滤不了,你的kafka上肯定还有个应用往下游写的,在这里过滤也可以做到。
所以方案我觉得怎么样都能做的,是可行的。
不过我觉得你的处理方法太绕了。我还是信奉“如无必要,勿增实体”。现在的问题是运维操作删除数据有可能误删除。应该想办法在源头解决问题,而不是发生了这个问题再去拦截。
如果能做到运维操作删除前先备份,保证删除可回退,就算这些操作被复制到下游也是能挽回的就好了。
放任源头不管,会增加很多解决问题的复杂度。最后很容易引入更大的麻烦。