Struct KafkaMessage 

pub struct KafkaMessage { /* private fields */ }

Kafka Message.

Implementations

impl KafkaMessage

pub fn new(value: impl Into<Bytes>) -> Self

Creates a new value.

pub fn tombstone() -> Self

Tombstone.

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

Sets topic and returns the updated value.

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

Sets partition and returns the updated value.

pub fn with_key(self, key: impl Into<Bytes>) -> Self

Sets key and returns the updated value.

pub fn with_timestamp(self, timestamp: i64) -> Self

Sets timestamp and returns the updated value.

pub fn with_null_value(self) -> Self

Sets null value and returns the updated value.

pub fn with_header(self, header: RecordHeader) -> Self

Sets header and returns the updated value.

pub fn with_headers<I>(self, headers: I) -> Self

where I: IntoIterator<Item = RecordHeader>,

Sets headers and returns the updated value.

pub fn into_record( self, default_topic: Option<&str>, default_partition: Option<i32>, ) -> Result<ProduceRecord>

Converts this value into record.

Trait Implementations

impl Clone for KafkaMessage

fn clone(&self) -> KafkaMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaMessage

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

Formats the value using the given formatter.

impl From<ProduceRecord> for KafkaMessage

fn from(record: ProduceRecord) -> Self

Converts to this type from the input type.

impl<T> From<T> for KafkaMessage

where T: Into<Bytes>,

fn from(value: T) -> Self

Converts to this type from the input type.