Skip to main content

resolve_glue_schemas

mz_testdrive::action::kafka::verify_data

Function resolve_glue_schemas 

Source 
async fn resolve_glue_schemas(
    state: &State,
    records: &[Record<Vec<u8>>],
    format: &mut RecordFormat,
) -> Result<(Option<Schema>, Option<Schema>), Error>
Expand description

Resolve the writer schema for each record side from AWS Glue.

Reads the schema-version UUID from the Glue header of the first record on each side and fetches that version’s definition from Glue. Returns (key_schema, value_schema), mirroring the Confluent resolution path, and sets format.requires_key when a key schema is present. All records in a verify batch share the sink’s schema, so one lookup per side is enough.