Struct kafka_api::fetch_response::PartitionData

pub struct PartitionData {
    pub partition_index: i32,
    pub error_code: i16,
    pub high_watermark: i64,
    pub last_stable_offset: i64,
    pub log_start_offset: i64,
    pub diverging_epoch: Option<EpochEndOffset>,
    pub current_leader: Option<LeaderIdAndEpoch>,
    pub snapshot_id: Option<SnapshotId>,
    pub aborted_transactions: Option<Vec<AbortedTransaction>>,
    pub preferred_read_replica: i32,
    pub records: Bytes,
    pub unknown_tagged_fields: Vec<RawTaggedField>,
}

Fields

partition_index: i32

The topic name.

error_code: i16

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

high_watermark: i64

The current high water mark.

last_stable_offset: i64

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).

log_start_offset: i64

The current log start offset.

diverging_epoch: Option<EpochEndOffset>

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

current_leader: Option<LeaderIdAndEpoch>

snapshot_id: Option<SnapshotId>

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.

aborted_transactions: Option<Vec<AbortedTransaction>>

The aborted transactions.

preferred_read_replica: i32

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

records: Bytes

The record data.

unknown_tagged_fields: Vec<RawTaggedField>

Unknown tagged fields.

Trait Implementations

impl Clone for PartitionData

fn clone(&self) -> PartitionData

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionData

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

Formats the value using the given formatter.

impl Default for PartitionData

fn default() -> PartitionData

Returns the “default value” for a type.

impl Encodable for PartitionData

fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<()>