pub type RDKafkaMessage = rd_kafka_message_t;Expand description
Native rdkafka message.
Aliased Type§
struct RDKafkaMessage {
pub err: rd_kafka_resp_err_t,
pub rkt: *mut rd_kafka_topic_s,
pub partition: i32,
pub payload: *mut c_void,
pub len: usize,
pub key: *mut c_void,
pub key_len: usize,
pub offset: i64,
pub _private: *mut c_void,
}Fields§
§err: rd_kafka_resp_err_t§rkt: *mut rd_kafka_topic_s§partition: i32§payload: *mut c_void§len: usize§key: *mut c_void§key_len: usize§offset: i64§_private: *mut c_void