Enum SeekTarget 

pub enum SeekTarget {
    MessageId(MessageId),
    PublishTimeMs(u64),
}

Per-topic seek target supplied by the closure passed to crate::MultiTopicsConsumer::seek_per_partition (and the equivalent on crate::PartitionedConsumer). Mirrors Java’s Consumer#seek(Function<String, Object>), where the function returns either a MessageId or a Long publish-time millis-since-epoch.

Variants

MessageId(MessageId)

Seek the child consumer to a specific message id. Mirrors Java Consumer#seek(MessageId).

PublishTimeMs(u64)

Seek the child consumer to a publish-time deadline (millis since UNIX epoch). Mirrors Java Consumer#seek(long).

Trait Implementations

impl Clone for SeekTarget

fn clone(&self) -> SeekTarget

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SeekTarget

impl Debug for SeekTarget

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

Formats the value using the given formatter.

impl Eq for SeekTarget

impl PartialEq for SeekTarget

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SeekTarget