我一直在尝试找到一种方法，在 debezium 源 sql 连接器中包含一个过滤器，该过滤器会丢弃具有特定值的记录。可以说，我有 JSON:{“id”:0，“name”:“muj”}，并且我想丢弃“name”字段值为“muj”的所有记录。有没有一种方法可以做到这一点而不必使用融合平台？
最佳答案
您可以使用 Kafka Connect 转换的过滤功能(来自 Confluence 的功能)。过滤器函数允许根据记录值包含或排除与谓词匹配的记录。请参阅transforms/filter文档和示例。
关于json - kafka connect中按某个值过滤记录，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60181978/