Struct FetchResponsePartition 

pub struct FetchResponsePartition {
    pub partition_index: Int32,
    pub error_code: Option<Error>,
    pub high_watermark: Int64,
    pub last_stable_offset: Option<Int64>,
    pub aborted_transactions: Vec<FetchResponseAbortedTransaction>,
    pub records: Records,
}

Fields

partition_index: Int32

The partition index.

error_code: Option<Error>

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

high_watermark: Int64

The current high water mark.

last_stable_offset: Option<Int64>

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

Added in version 4.

aborted_transactions: Vec<FetchResponseAbortedTransaction>

The aborted transactions.

Added in version 4.

records: Records

The record data.

Trait Implementations

impl Debug for FetchResponsePartition

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

Formats the value using the given formatter.

impl<R> ReadVersionedType<R> for FetchResponsePartition

where R: Read,

fn read_versioned( reader: &mut R, version: ApiVersion, ) -> Result<Self, ReadVersionedError>