Struct kafka_api::fetch_request::FetchPartition

pub struct FetchPartition {
    pub partition: i32,
    pub current_leader_epoch: i32,
    pub fetch_offset: i64,
    pub last_fetched_epoch: i32,
    pub log_start_offset: i64,
    pub partition_max_bytes: i32,
    pub unknown_tagged_fields: Vec<RawTaggedField>,
}

Fields

partition: i32

The partition index.

current_leader_epoch: i32

The current leader epoch of the partition.

fetch_offset: i64

The message offset.

last_fetched_epoch: i32

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

log_start_offset: i64

The earliest available offset of the follower replica.

The field is only used when the request is sent by the follower.

partition_max_bytes: i32

The maximum bytes to fetch from this partition.

See KIP-74 for cases where this limit may not be honored.

unknown_tagged_fields: Vec<RawTaggedField>

Unknown tagged fields.

Trait Implementations

impl Clone for FetchPartition

fn clone(&self) -> FetchPartition

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FetchPartition

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

Formats the value using the given formatter.

impl Decodable for FetchPartition

fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self>

impl Default for FetchPartition

fn default() -> FetchPartition

Returns the “default value” for a type.