Function mz_testdrive::action::kafka::verify_data::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>