Struct rdkafka::producer::future_producer::FutureRecord

pub struct FutureRecord<'a, K: ToBytes + ?Sized, P: ToBytes + ?Sized> {
    pub topic: &'a str,
    pub partition: Option<i32>,
    pub payload: Option<&'a P>,
    pub key: Option<&'a K>,
    pub timestamp: Option<i64>,
    pub headers: Option<OwnedHeaders>,
}

A record for the future producer.

Like BaseRecord, but specific to the FutureProducer. The only difference is that the FutureRecord doesn’t provide custom delivery opaque object.

Fields

topic: &'a str

Required destination topic.

partition: Option<i32>

Optional destination partition.

payload: Option<&'a P>

Optional payload.

key: Option<&'a K>

Optional key.

timestamp: Option<i64>

Optional timestamp.

headers: Option<OwnedHeaders>

Optional message headers.

Implementations

impl<'a, K: ToBytes + ?Sized, P: ToBytes + ?Sized> FutureRecord<'a, K, P>

pub fn to(topic: &'a str) -> FutureRecord<'a, K, P>

Creates a new record with the specified topic name.

pub fn partition(self, partition: i32) -> FutureRecord<'a, K, P>

Sets the destination partition of the record.

pub fn payload(self, payload: &'a P) -> FutureRecord<'a, K, P>

Sets the destination payload of the record.

pub fn key(self, key: &'a K) -> FutureRecord<'a, K, P>

Sets the destination key of the record.

pub fn timestamp(self, timestamp: i64) -> FutureRecord<'a, K, P>

Sets the destination timestamp of the record.

pub fn headers(self, headers: OwnedHeaders) -> FutureRecord<'a, K, P>

Sets the headers of the record.

Trait Implementations

impl<'a, K: Debug + ToBytes + ?Sized, P: Debug + ToBytes + ?Sized> Debug for FutureRecord<'a, K, P>

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

Formats the value using the given formatter.