Module mz_interchange::confluent

Functions

• extract_avro_header
• extract_protobuf_header
• extract_schema_id 🔒
  Extracts the schema_id placed in front of the serialized message by the confluent stack Optionally expect an empty