mz_storage::sink::kafka

Function encode_headers

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