mz_testdrive::action::kafka::verify_data

Function decode_messages

Source 
fn decode_messages(
    actual_bytes: Vec<Record<Vec<u8>>>,
    key_schema: &Option<Schema>,
    value_schema: &Option<Schema>,
    format: &RecordFormat,
) -> Result<Vec<Record<DecodedValue>>, Error>