Function interchange::confluent::extract_schema_id[][src]

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

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 sublice of the rest of the buffer