Struct OffsetManager 

pub struct OffsetManager { /* private fields */ }

Manages consumer offsets for topics and partitions

Implementations

impl OffsetManager

pub fn new() -> Self

Create a new offset manager

pub async fn commit_offset( &self, consumer_group: &str, topic: &str, partition: u32, offset: u64, )

Commit an offset for a consumer group

pub async fn get_offset( &self, consumer_group: &str, topic: &str, partition: u32, ) -> Option<u64>

Get the committed offset for a consumer group

pub async fn reset_offsets(&self, consumer_group: &str)

Reset offsets for a consumer group

pub async fn list_groups(&self) -> Vec<String>

List all consumer groups with committed offsets

pub async fn get_group_offsets( &self, consumer_group: &str, ) -> Option<HashMap<String, HashMap<u32, u64>>>

Get all offsets for a consumer group Returns: topic → partition → offset

pub async fn delete_group(&self, consumer_group: &str) -> bool

Delete a consumer group and all its offsets

Trait Implementations

impl Clone for OffsetManager

fn clone(&self) -> OffsetManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffsetManager

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

Formats the value using the given formatter.

impl Default for OffsetManager

fn default() -> Self

Returns the “default value” for a type.