用于Server的Debezium连接器，并希望在debezium层执行过滤

Question

我们正在为Server使用debezium连接器，并且希望在debezium层本身执行过滤，这样我们就可以有选择地将数据传递到kafka主题上。

Answer 1

您可以查看以下文档：https://debezium.io/documentation/reference/stable/transformations/filtering.html

你可能需要这样的东西：

"transforms": "filter",
"transforms.filter.type": "io.debezium.transforms.Filter",
"transforms.filter.language": "jsr223.groovy",
"transforms.filter.condition": "value.op == \"c\""