mz_
storage
0.0.0
In mz_
storage::
sink::
kafka
mz_storage
::
sink
::
kafka
Function
parse_progress_record
Copy item path
Source
fn parse_progress_record(payload: &[
u8
]) ->
Result
<
ProgressRecord
,
Error
>