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.Nonewhen the id is malformed or does not contain enough segments.