Struct ConsumerRecordOptionsBuilder 

pub struct ConsumerRecordOptionsBuilder<K, V> { /* private fields */ }

Fluent builder for ConsumerRecordOptions: every parameter has a setter, and Self::build checks that the mandatory ones were set.

Implementations

impl<K, V> ConsumerRecordOptionsBuilder<K, V>

pub fn new() -> Self

Creates a builder with every mandatory parameter unset and every other parameter at the value Java passes on the caller’s behalf.

Returns

The new builder.

pub fn set_topic(self, topic: impl Into<Arc<str>>) -> Self

Sets ConsumerRecordOptions::topic, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• topic - The topic this record is received from

Returns

This builder.

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

Sets ConsumerRecordOptions::partition, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• partition - The partition of the topic this record is received from

Returns

This builder.

pub fn set_offset(self, offset: i64) -> Self

Sets ConsumerRecordOptions::offset, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• offset - The offset of this record in the corresponding Kafka partition

Returns

This builder.

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

Sets ConsumerRecordOptions::timestamp.

Arguments

• timestamp - The timestamp of the record.

Returns

This builder.

pub fn set_timestamp_type(self, timestamp_type: TimestampType) -> Self

Sets ConsumerRecordOptions::timestamp_type.

Arguments

• timestamp_type - The timestamp type

Returns

This builder.

pub fn set_serialized_key_size(self, serialized_key_size: i32) -> Self

Sets ConsumerRecordOptions::serialized_key_size.

Arguments

• serialized_key_size - The length of the serialized key

Returns

This builder.

pub fn set_serialized_value_size(self, serialized_value_size: i32) -> Self

Sets ConsumerRecordOptions::serialized_value_size.

Arguments

• serialized_value_size - The length of the serialized value

Returns

This builder.

pub fn set_key(self, key: Option<K>) -> Self

Sets ConsumerRecordOptions::key, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• key - The key of the record, if one exists (None is allowed)

Returns

This builder.

pub fn set_value(self, value: Option<V>) -> Self

Sets ConsumerRecordOptions::value, a mandatory parameter: Self::build returns an error if it was not set.

Arguments

• value - The record contents

Returns

This builder.

pub fn set_headers(self, headers: RecordHeaders) -> Self

Sets ConsumerRecordOptions::headers.

Arguments

• headers - The headers of the record

Returns

This builder.

pub fn set_leader_epoch(self, leader_epoch: Option<i32>) -> Self

Sets ConsumerRecordOptions::leader_epoch.

Arguments

• leader_epoch - Optional leader epoch of the record (may be empty for legacy record formats)

Returns

This builder.

pub fn set_delivery_count(self, delivery_count: Option<i16>) -> Self

Sets ConsumerRecordOptions::delivery_count.

Arguments

• delivery_count - Optional delivery count of the record (may be empty when deliveries not counted)

Returns

This builder.

pub fn build(self) -> Result<ConsumerRecordOptions<K, V>, Error>

Returns the built options.

Errors

• Error::is_local_illegal_argument_error naming the first of topic, partition, offset, key and value that was not set.

Trait Implementations

impl<K: Debug, V: Debug> Debug for ConsumerRecordOptionsBuilder<K, V>

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

Formats the value using the given formatter.

impl<K, V> Default for ConsumerRecordOptionsBuilder<K, V>

fn default() -> Self

Returns the “default value” for a type.