parse_schema_table_from_debezium_id

Function parse_schema_table_from_debezium_id 

Source
fn parse_schema_table_from_debezium_id(id: &str) -> Option<(String, String)>
Expand description

Parse Debezium tableChanges[].id into (schema_name, table_name).

Input examples observed in Debezium schema-change events:

  • "public"."orders" (quoted format)
  • public.orders (plain dotted format)
  • db.public.orders (database-prefixed dotted format)

Why two parsing branches:

  • Different Debezium versions/connectors may emit quoted or plain identifiers.
  • We normalize both forms so downstream lookup can consistently query upstream catalogs.

Output:

  • Some((schema, table)) when both schema and table are successfully extracted.
  • None when the id is malformed or does not contain enough segments.