Struct ListOffsetsRequestPartition 

pub struct ListOffsetsRequestPartition {
    pub partition_index: Int32,
    pub timestamp: Int64,
    pub max_num_offsets: Option<Int32>,
}

Fields

partition_index: Int32

The partition index.

timestamp: Int64

The current timestamp.

Depending on the version this will return:

• version 0: max_num_offsets offsets that are smaller/equal than this timestamp.
• version 1 and later: return timestamp and offset of the first/message greater/equal than this timestamp

Per KIP-79 this can have the following special values:

• -1: latest offset
• -2: earlist offset

max_num_offsets: Option<Int32>

The maximum number of offsets to report.

Defaults to 1.

Removed in version 1.

Trait Implementations

impl Debug for ListOffsetsRequestPartition

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

Formats the value using the given formatter.

impl<W> WriteVersionedType<W> for ListOffsetsRequestPartition

where W: Write,

fn write_versioned( &self, writer: &mut W, version: ApiVersion, ) -> Result<(), WriteVersionedError>