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
encode_headers
Copy item path
Settings
Help
Summary
Source
fn encode_headers(datum:
Datum
<'_>) ->
Vec
<
KafkaHeader
>