Function mz_storage::sink::kafka::parse_progress_record
source ยท fn parse_progress_record(payload: &[u8]) -> Result<ProgressRecord, Error>fn parse_progress_record(payload: &[u8]) -> Result<ProgressRecord, Error>