Enum kafka::client::FetchOffset
[−]
[src]
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
[src]
fn clone(&self) -> FetchOffset
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)
1.0.0
Performs copy-assignment from source
. Read more