Struct ConsumedMessage 

pub struct ConsumedMessage {
    pub offset: u64,
    pub timestamp: i64,
    pub key: Option<Bytes>,
    pub value: Bytes,
}

A consumed message with zero-copy data access

Fields

offset: u64

Message offset

timestamp: i64

Timestamp (milliseconds since epoch)

key: Option<Bytes>

Message key (zero-copy)

value: Bytes

Message value (zero-copy)

Implementations

impl ConsumedMessage

pub fn value_str(&self) -> Option<&str>

Get value as string (copies if not valid UTF-8)

pub fn key_str(&self) -> Option<&str>

Get key as string

Trait Implementations

impl Clone for ConsumedMessage

fn clone(&self) -> ConsumedMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumedMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.