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

Posted 2023-03-23

【中文标题】SQL Server 的 Debezium 连接器，并希望在 debezium 层进行过滤

【英文标题】：Debezium connector for SQL Server and want to do the filteration at debezium layer

【发布时间】：2021-12-27 17:09:50

【问题描述】：

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

【参考方案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\""