Skip to main content

decode

faucet_stream::source::kafka::decode

Function decode 

Source 
pub async fn decode(
    bytes: Option<&[u8]>,
    format: &KafkaValueFormat,
    sr_client: Option<&SchemaRegistryClient>,
) -> Result<Value, FaucetError>
Available on crate features source-kafka and source-rest only.
Expand description

Decode bytes per format. For Confluent SR formats, sr_client must be Some.