Struct kafka_protocol::messages::fetch_response::PartitionDataBuilder

pub struct PartitionDataBuilder { /* private fields */ }

Builder for PartitionData.

Implementations

impl PartitionDataBuilder

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

The partition index.

Supported API versions: 0-13

pub fn error_code(&mut self, value: i16) -> &mut Self

The error code, or 0 if there was no fetch error.

Supported API versions: 0-13

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

The current high water mark.

Supported API versions: 0-13

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

The last stable offset (or LSO) of the partition. This is the last offset such that the state of all transactional records prior to this offset have been decided (ABORTED or COMMITTED)

Supported API versions: 4-13

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

The current log start offset.

Supported API versions: 5-13

pub fn diverging_epoch(&mut self, value: EpochEndOffset) -> &mut Self

In case divergence is detected based on the LastFetchedEpoch and FetchOffset in the request, this field indicates the largest epoch and its end offset such that subsequent records are known to diverge

Supported API versions: 12-13

pub fn current_leader(&mut self, value: LeaderIdAndEpoch) -> &mut Self

Supported API versions: 12-13

pub fn snapshot_id(&mut self, value: SnapshotId) -> &mut Self

In the case of fetching an offset less than the LogStartOffset, this is the end offset and epoch that should be used in the FetchSnapshot request.

Supported API versions: 12-13

pub fn aborted_transactions(
    &mut self,
    value: Option<Vec<AbortedTransaction>>
) -> &mut Self

The aborted transactions.

Supported API versions: 4-13

pub fn preferred_read_replica(&mut self, value: BrokerId) -> &mut Self

The preferred read replica for the consumer to use on its next fetch request

Supported API versions: 11-13

pub fn records(&mut self, value: Option<Bytes>) -> &mut Self

The record data.

Supported API versions: 0-13

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

Other tagged fields

pub fn build(&self) -> Result<PartitionData, PartitionDataBuilderError>

Builds a new PartitionData.

Errors

If a required field has not been initialized.

Trait Implementations

impl Clone for PartitionDataBuilder

fn clone(&self) -> PartitionDataBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for PartitionDataBuilder

fn default() -> Self

Returns the “default value” for a type.