Struct ProduceRecord 

pub struct ProduceRecord {
    pub topic: String,
    pub partition: Option<i32>,
    pub timestamp: Option<i64>,
    pub headers: Vec<RecordHeader>,
    pub key: Option<Bytes>,
    pub value: Option<Bytes>,
}

Produce Record.

Fields

topic: String

Topic name.

partition: Option<i32>

Partition number.

timestamp: Option<i64>

Timestamp.

headers: Vec<RecordHeader>

Headers.

key: Option<Bytes>

Record key.

value: Option<Bytes>

Record value.

Implementations

impl ProduceRecord

pub fn new( topic: impl Into<String>, partition: impl Into<Option<i32>>, value: impl Into<Bytes>, ) -> Self

Creates a new value.

pub fn without_partition( topic: impl Into<String>, value: impl Into<Bytes>, ) -> Self

Without Partition.

pub fn to_partition( topic: impl Into<String>, partition: i32, value: impl Into<Bytes>, ) -> Self

To Partition.

pub fn tombstone( topic: impl Into<String>, partition: impl Into<Option<i32>>, ) -> Self

Tombstone.

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.

Trait Implementations

impl Clone for ProduceRecord

fn clone(&self) -> ProduceRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProduceRecord

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.