Struct rdkafka::consumer::Message

pub struct Message<'a> {
    pub payload: Option<&'a [u8]>,
    pub key: Option<&'a [u8]>,
    pub partition: i32,
    pub offset: i64,
    pub message_n: *mut rd_kafka_message_s,
}

Fields

payload: Option<&'a [u8]>

key: Option<&'a [u8]>

partition: i32

offset: i64

message_n: *mut rd_kafka_message_s

Trait Implementations

impl<'a> Debug for Message<'a>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a> Drop for Message<'a>

fn drop(&mut self)

A method called when the value goes out of scope.