Skip to main content

encode_headers

mz_storage::sink::kafka

Function encode_headers 

Source 
fn encode_headers(datum: Datum<'_>) -> Vec<KafkaHeader>