Struct kafka_protocol::messages::offset_for_leader_epoch_request::OffsetForLeaderPartitionBuilder

pub struct OffsetForLeaderPartitionBuilder { /* private fields */ }

Builder for OffsetForLeaderPartition.

Implementations

impl OffsetForLeaderPartitionBuilder

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

The partition index.

Supported API versions: 0-4

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

An epoch used to fence consumers/replicas with old metadata. If the epoch provided by the client is larger than the current epoch known to the broker, then the UNKNOWN_LEADER_EPOCH error code will be returned. If the provided epoch is smaller, then the FENCED_LEADER_EPOCH error code will be returned.

Supported API versions: 2-4

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

The epoch to look up an offset for.

Supported API versions: 0-4

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

Other tagged fields

pub fn build(
    &self
) -> Result<OffsetForLeaderPartition, OffsetForLeaderPartitionBuilderError>

Builds a new OffsetForLeaderPartition.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for OffsetForLeaderPartitionBuilder

fn clone(&self) -> OffsetForLeaderPartitionBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for OffsetForLeaderPartitionBuilder

fn default() -> Self

Returns the “default value” for a type.