Struct kafka_protocol::messages::txn_offset_commit_request::TxnOffsetCommitRequestPartitionBuilder

pub struct TxnOffsetCommitRequestPartitionBuilder { /* private fields */ }

Builder for TxnOffsetCommitRequestPartition.

Implementations

impl TxnOffsetCommitRequestPartitionBuilder

pub fn partition_index(&mut self, value: i32) -> &mut Self

The index of the partition within the topic.

Supported API versions: 0-3

pub fn committed_offset(&mut self, value: i64) -> &mut Self

The message offset to be committed.

Supported API versions: 0-3

pub fn committed_leader_epoch(&mut self, value: i32) -> &mut Self

The leader epoch of the last consumed record.

Supported API versions: 2-3

pub fn committed_metadata(&mut self, value: Option<StrBytes>) -> &mut Self

Any associated metadata the client wants to keep.

Supported API versions: 0-3

pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes> ) -> &mut Self

Other tagged fields

pub fn build( &self ) -> Result<TxnOffsetCommitRequestPartition, TxnOffsetCommitRequestPartitionBuilderError>

Builds a new TxnOffsetCommitRequestPartition.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for TxnOffsetCommitRequestPartitionBuilder

fn clone(&self) -> TxnOffsetCommitRequestPartitionBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for TxnOffsetCommitRequestPartitionBuilder

fn default() -> Self

Returns the “default value” for a type.