您正在查看 Debezium 未发布版本的文档。
如果您想查看此页面的最新稳定版本,请在此 查看。

Vitess 过滤事务主题记录

当 Vitess 连接器配置为提供事务元数据时,请使用 FilterTransactionTopicRecords SMT 来阻止连接器将事务边界事件发送到事务主题。此转换仅设计用于 Debezium Vitess 连接器。

要过滤事件,SMT 会检查每条记录的键和值模式是否匹配,并将其与 TransactionStructMaker 返回的值进行比较。以下示例显示了如何将 FilterTransactionTopicRecords SMT 添加到连接器配置中,以删除连接器发出的所有事务边界事件记录,并阻止它们保存到事务主题。

示例:配置 FilterTransactionTopicRecords SMT 以过滤掉所有事务边界事件记录

"connector.class": "io.debezium.connector.vitess.VitessConnector",
...
"transforms": "filterTransactionTopicRecords",
"transforms.filterTransactionTopicRecords.type": "io.debezium.connector.vitess.transforms.FilterTransactionTopicRecords",
...