Struct StreamMessage 

pub struct StreamMessage {
    pub offset: StreamOffset,
    pub key: Option<Vec<u8>>,
    pub payload: Vec<u8>,
    pub timestamp: Option<u64>,
    pub headers: HashMap<String, String>,
    pub source: String,
}

A message consumed from an external stream.

Fields

offset: StreamOffset

Unique offset/ID within the stream (for commit tracking).

key: Option<Vec<u8>>

Message key (for partitioning).

payload: Vec<u8>

Message payload.

timestamp: Option<u64>

Timestamp from the source stream.

headers: HashMap<String, String>

Headers/metadata.

source: String

Source topic/subject/stream name.

Trait Implementations

impl Clone for StreamMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMessage

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

Formats the value using the given formatter.