Struct ProducerRecord 

pub struct ProducerRecord {
    pub topic: String,
    pub key: Option<Bytes>,
    pub payload: Option<Bytes>,
    pub partition: Option<i32>,
    pub timestamp: Option<i64>,
    pub headers: Vec<KafkaHeader>,
}

Owned Kafka producer record.

Fields

topic: String

key: Option<Bytes>

payload: Option<Bytes>

partition: Option<i32>

timestamp: Option<i64>

headers: Vec<KafkaHeader>

Implementations

impl ProducerRecord

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

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

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

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

pub fn with_header( self, key: impl Into<String>, value: impl Into<Option<Bytes>>, ) -> Self

Trait Implementations

impl Clone for ProducerRecord

fn clone(&self) -> ProducerRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProducerRecord

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

Formats the value using the given formatter.

impl Eq for ProducerRecord

impl PartialEq for ProducerRecord

fn eq(&self, other: &ProducerRecord) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ProducerRecord