You are viewing documentation for an unreleased version of Debezium.
If you want to view the latest stable version of this page, please go here.

Vitess Filter Transaction Topic Records

When the Vitess connector is configured to provide transaction metadata, use the FilterTransactionTopicRecords SMT to prevent the connector from sending transaction boundary events to transaction topics. This transformation is designed for use only with the Debezium connector for Vitess.

To filter events, the SMT checks the key and value schemas of each record match and compares them to the values returned by TransactionStructMaker. The following example shows how to add the FilterTransactionTopicRecords SMT to the connector configuration to remove all transaction boundary event records that the connector emits, and prevent them from being saved to the transaction topic.

Example: Configuring the FilterTransactionTopicRecords SMT to filter out all transaction boundary event records

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