Enum kafka::client::FetchOffset

pub enum FetchOffset {
    Earliest,
    Latest,
    ByTime(i64),
}

Possible values when querying a topic's offset. See KafkaClient::fetch_offsets.

Variants

Earliest

Receive the earliest available offset.

Latest

Receive the latest offset.

ByTime(i64)

Used to ask for all messages before a certain time (ms); unix timestamp in milliseconds. See also https://cwiki.apache.org/confluence/display/KAFKA/Writing+a+Driver+for+Kafka#WritingaDriverforKafka-Offsets

Trait Implementations

impl Clone for FetchOffset

fn clone(&self) -> FetchOffset

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for FetchOffset

impl Debug for FetchOffset

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.