Trait OffsetStore 

pub trait OffsetStore {
    // Required methods
    fn commit(&mut self, topic: &str, partition: u32, group: &str, offset: u64);
    fn fetch(&self, topic: &str, partition: u32, group: &str) -> Option<u64>;
}

Trait for persisting consumer offsets.

Required Methods

fn commit(&mut self, topic: &str, partition: u32, group: &str, offset: u64)

Commit the offset for a given topic/partition/group.

fn fetch(&self, topic: &str, partition: u32, group: &str) -> Option<u64>

Fetch the last committed offset for a given topic/partition/group. Returns None if no offset has been committed.

Implementors

impl OffsetStore for MemOffsetStore