Enum 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

Available on non-madsim only.

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

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

Available on non-madsim only.

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

Available on non-madsim only.

fn clone(&self) -> Offset

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Offset

Available on non-madsim only.

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

Formats the value using the given formatter.

impl PartialEq for Offset

Available on non-madsim only.

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

Available on non-madsim only.

impl Eq for Offset

Available on non-madsim only.

impl StructuralPartialEq for Offset

Available on non-madsim only.