Module debezium

Macros

jsonb_access_field 🔒

Structs

DebeziumChangeEvent

MongoJsonAccess

Access support for Mongo

Constants

AFTER 🔒

BEFORE 🔒

DEBEZIUM_CREATE_OP

DEBEZIUM_DELETE_OP

DEBEZIUM_READ_OP

DEBEZIUM_TRANSACTION_STATUS_BEGIN

DEBEZIUM_TRANSACTION_STATUS_COMMIT

DEBEZIUM_UPDATE_OP

OP 🔒

SOURCE 🔒

SOURCE_COLLECTION 🔒

SOURCE_DB 🔒

SOURCE_SCHEMA 🔒

SOURCE_TABLE 🔒

SOURCE_TS_MS 🔒

TABLE_CHANGES

TRANSACTION_ID

TRANSACTION_STATUS

UPSTREAM_DDL 🔒

Functions

bson_extract_date 🔒

bson_extract_number 🔒

bson_extract_timestamp 🔒

extract_bson_field

Extract the field data from the bson document

extract_bson_id

parse_schema_change

Parse the schema change message from Debezium. The layout of MySQL schema change message can refer to https://debezium.io/documentation/reference/2.6/connectors/mysql.html#mysql-schema-change-topic

parse_transaction_meta