Struct MemOffsetStore 

pub struct MemOffsetStore { /* private fields */ }

In-memory offset store backed by a BTreeMap.

Implementations

impl MemOffsetStore

pub fn new() -> Self

Create a new empty offset store.

Trait Implementations

impl Default for MemOffsetStore

fn default() -> Self

Returns the “default value” for a type.

impl OffsetStore for MemOffsetStore

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.