Skip to main content

decode_avro

Function decode_avro 

Source
pub fn decode_avro(schema: &Schema, bytes: &[u8]) -> Result<Value>
Expand description

Decode Avro-binary bytes into a serde_json::Value using the given schema.

The schema must match the schema_id on the event header.

ยงErrors

Returns PubSubError::Avro if the bytes cannot be decoded with the provided schema.