mz_
storage
0.0.0
In mz_
storage::
sink::
kafka
Structs
KafkaHeader
KafkaMessage
LegacyProgressRecord
ProgressRecord
TransactionalProducer
Functions
collect_statistics
deserialize_frontier
deserialize_some
determine_sink_progress
encode_collection
encode_headers
evaluate_partition_by
fetch_partition_count
fetch_partition_count_loop
parse_progress_record
progress_search
serialize_frontier
sink_collection
mz_storage
::
sink
::
kafka
Function
parse_progress_record
Copy item path
Settings
Help
Summary
Source
fn parse_progress_record(payload: &[
u8
]) ->
Result
<
ProgressRecord
,
Error
>