mz_storage::sink::kafka

Function encode_headers

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