Struct KafkaMessage 

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

Message to be sent to Kafka

Fields

payload: T

Message payload

key: Option<String>

Message key (optional)

topic: Option<String>

Target topic (uses default if None)

partition: Option<i32>

Target partition (for custom partitioning)

headers: HashMap<String, String>

Message headers

timestamp: Option<DateTime<Utc>>

Timestamp

Implementations

impl<T> KafkaMessage<T>

pub fn new(payload: T) -> Self

Create a new message with payload

pub fn with_key(self, key: String) -> Self

Set message key

pub fn with_topic(self, topic: String) -> Self

Set topic

pub fn with_partition(self, partition: i32) -> Self

Set partition

pub fn with_header(self, key: String, value: String) -> Self

Add header

pub fn with_timestamp(self, timestamp: DateTime<Utc>) -> Self

Set timestamp

Trait Implementations

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

fn clone(&self) -> KafkaMessage<T>

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.