risingwave_connector::parser::unified::debezium

Function parse_schema_change

source 
pub fn parse_schema_change(
    accessor: &impl Access,
    source_id: u32,
    connector_props: &ConnectorProperties,
) -> AccessResult<SchemaChangeEnvelope>
Expand description

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