在kafka connect中按某个值过滤记录

Muj*_*izi 5 sql-server json apache-kafka apache-kafka-connect debezium

我一直试图找到一种方法,在 debezium 源 sql 连接器中包含一个过滤器,该过滤器丢弃具有特定值的记录。比方说,我有 JSON: {"id":0, "name":"muj"} 并且我想丢弃所有字段“name”值为“muj”的记录。有没有办法在不必使用融合平台的情况下做到这一点?