Function kafka_serde::from_bytes

pub fn from_bytes<'de, T>(buf: &'de [u8]) -> Result<T> where
    T: Deserialize<'de>, 

Deserialize a kafka payload contained in a byte slice

Examples

use serde::Deserialize;

#[derive(Deserialize, Debug, Default)]
struct ResponseHeader {
    correlation_id: i32,
}

fn get_header(data: &[u8]) -> kafka_serde::Result<ResponseHeader> {
    let resp: ResponseHeader = kafka_serde::from_bytes(data)?;
    Ok(resp)
}