SQL 服务器的 Debezium 连接器并希望在 debezium 层进行过滤

Question

我们正在为 SQL 服务器使用 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\""

SQL 服务器的 Debezium 连接器并希望在 debezium 层进行过滤

Debezium connector for SQL Server and want to do the filteration at debezium layer

debezium