Function mz_interchange::confluent::extract_schema_id

fn extract_schema_id<'buf>(
    buf: &'buf [u8],
    protocol: &str,
) -> Result<(i32, &'buf [u8])>

Extracts the schema_id placed in front of the serialized message by the confluent stack Optionally expect an empty

This function returns the schema_id and a subslice of the rest of the buffer