Enum OffsetSpec 

#[non_exhaustive]
pub enum OffsetSpec {
    Earliest,
    Latest,
    MaxTimestamp,
    EarliestLocal,
    LatestTiered,
    EarliestPendingUpload,
    Timestamp(i64),
}

Specifies the desired offsets when using Admin::list_offsets.

Corresponds to org.apache.kafka.clients.admin.OffsetSpec. Java models the variants as nested subclasses of OffsetSpec; the Rust translation uses a single closed enum since the variants carry no behavior beyond their timestamp mapping (getOffsetFromSpec).

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Earliest

Retrieve the earliest offset of a partition.

Mirrors OffsetSpec.EarliestSpec.

Latest

Retrieve the latest offset of a partition.

Mirrors OffsetSpec.LatestSpec.

MaxTimestamp

Retrieve the offset with the largest timestamp of a partition.

Mirrors OffsetSpec.MaxTimestampSpec.

EarliestLocal

Retrieve the local log start offset.

Mirrors OffsetSpec.EarliestLocalSpec.

LatestTiered

Retrieve the highest offset of data stored in remote storage.

Mirrors OffsetSpec.LatestTieredSpec.

EarliestPendingUpload

Retrieve the earliest offset of records pending upload to remote storage.

Mirrors OffsetSpec.EarliestPendingUploadSpec.

Timestamp(i64)

Retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp (in milliseconds).

Mirrors OffsetSpec.TimestampSpec.

Implementations

impl OffsetSpec

pub fn latest() -> Self

Used to retrieve the latest offset of a partition.

Mirrors OffsetSpec.latest().

pub fn earliest() -> Self

Used to retrieve the earliest offset of a partition.

Mirrors OffsetSpec.earliest().

pub fn for_timestamp(timestamp: i64) -> Self

Used to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp (in milliseconds).

Mirrors OffsetSpec.forTimestamp(long).

pub fn max_timestamp() -> Self

Used to retrieve the offset with the largest timestamp of a partition.

Mirrors OffsetSpec.maxTimestamp().

pub fn earliest_local() -> Self

Used to retrieve the local log start offset.

Mirrors OffsetSpec.earliestLocal().

pub fn latest_tiered() -> Self

Used to retrieve the highest offset of data stored in remote storage.

Mirrors OffsetSpec.latestTiered().

pub fn earliest_pending_upload() -> Self

Used to retrieve the earliest offset of records pending upload to remote storage.

Mirrors OffsetSpec.earliestPendingUpload().

Trait Implementations

impl Clone for OffsetSpec

fn clone(&self) -> OffsetSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetSpec

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

Formats the value using the given formatter.

impl PartialEq for OffsetSpec

fn eq(&self, other: &OffsetSpec) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for OffsetSpec

impl Eq for OffsetSpec

impl StructuralPartialEq for OffsetSpec