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

【问题标题】：Debezium connector for SQL Server and want to do the filteration at debezium layerSQL Server 的 Debezium 连接器，并希望在 debezium 层进行过滤
【发布时间】：2021-12-27 17:09:50
【问题描述】：

我们正在为 SQL Server 使用 debezium 连接器，并希望在 debezium 层本身进行过滤，以便我们可以选择性地将数据传递到 kafka 主题

【问题讨论】：

标签： debezium

【解决方案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\""

【讨论】：