Struct KafkaMessage 

pub struct KafkaMessage<T> {
    pub payload: T,
    pub key: Option<Vec<u8>>,
    pub topic: String,
    pub partition: i32,
    pub offset: i64,
    pub timestamp: Option<DateTime<Utc>>,
    pub headers: HashMap<String, Vec<u8>>,
}

Message envelope with metadata

Fields

payload: T

Deserialized payload

key: Option<Vec<u8>>

Message key (if present)

topic: String

Topic name

partition: i32

Partition

offset: i64

Offset

timestamp: Option<DateTime<Utc>>

Timestamp (if available)

headers: HashMap<String, Vec<u8>>

Headers (if present)

Trait Implementations

impl<T: Clone> Clone for KafkaMessage<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for KafkaMessage<T>

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

Formats the value using the given formatter.