mz_storage::sink::kafka

Function parse_progress_record

Source
fn parse_progress_record(payload: &[u8]) -> Result<ProgressRecord, Error>