mz_testdrive::action::kafka::verify_data

Function parse_expected_messages

Source 
fn parse_expected_messages(
    expected_messages: Vec<String>,
    key_schema: Option<Schema>,
    value_schema: Option<Schema>,
    format: &RecordFormat,
    header_keys: &[String],
) -> Result<Vec<Record<DecodedValue>>, Error>