Enum rdkafka::topic_partition_list::Offset

pub enum Offset {
    Beginning,
    End,
    Stored,
    Invalid,
    Offset(i64),
    OffsetTail(i64),
}

A Kafka offset.

Variants

Beginning

Start consuming from the beginning of the partition.

End

Start consuming from the end of the partition.

Stored

Start consuming from the stored offset.

Invalid

Offset not assigned or invalid.

Offset(i64)

A specific offset to consume from.

Note that while the offset is a signed integer, negative offsets will be rejected when passed to librdkafka.

OffsetTail(i64)

An offset relative to the end of the partition.

Note that while the offset is a signed integer, negative offsets will be rejected when passed to librdkafka.

Implementations

impl Offset

pub fn from_raw(raw_offset: i64) -> Offset

Converts the integer representation of an offset used by librdkafka to an Offset.

pub fn to_raw(self) -> Option<i64>

Converts the Offset to the internal integer representation used by librdkafka.

Returns None if the offset cannot be represented in librdkafka’s internal representation.

Trait Implementations

impl Clone for Offset

fn clone(&self) -> Offset

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Offset

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

Formats the value using the given formatter.

impl PartialEq for Offset

fn eq(&self, other: &Offset) -> 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 Offset

impl Eq for Offset

impl StructuralPartialEq for Offset