Struct kafka_protocol::messages::fetch_request::FetchPartitionBuilder

pub struct FetchPartitionBuilder { /* private fields */ }

Builder for FetchPartition.

Implementations

impl FetchPartitionBuilder

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

The partition index.

Supported API versions: 0-16

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

The current leader epoch of the partition.

Supported API versions: 9-16

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

The message offset.

Supported API versions: 0-16

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

The epoch of the last fetched record or -1 if there is none

Supported API versions: 12-16

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

The earliest available offset of the follower replica. The field is only used when the request is sent by the follower.

Supported API versions: 5-16

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

The maximum bytes to fetch from this partition. See KIP-74 for cases where this limit may not be honored.

Supported API versions: 0-16

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

Other tagged fields

pub fn build(&self) -> Result<FetchPartition, FetchPartitionBuilderError>

Builds a new FetchPartition.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for FetchPartitionBuilder

fn clone(&self) -> FetchPartitionBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for FetchPartitionBuilder

fn default() -> Self

Returns the “default value” for a type.