Struct ConsumerGroup 

pub struct ConsumerGroup {
    pub name: String,
    pub consumers: HashMap<String, ConsumerState>,
    pub last_delivered_seq: u64,
    pub idle_timeout: Duration,
}

A named group of consumers sharing a single CDC stream.

The group maintains a high-watermark (last_delivered_seq) so that each new read delivers only events that no consumer in the group has seen yet. Individual consumer state is tracked in ConsumerState.

Fields

name: String

Human-readable group name.

consumers: HashMap<String, ConsumerState>

Per-consumer tracking state, keyed by consumer name.

last_delivered_seq: u64

Next sequence to deliver (high watermark for the group).

idle_timeout: Duration

Duration after which an unacknowledged entry becomes reclaimable.

Implementations

impl ConsumerGroup

pub fn new(name: String, start_seq: u64, idle_timeout: Duration) -> Self

Create a consumer group that begins reading at start_seq.

Trait Implementations

impl Debug for ConsumerGroup

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

Formats the value using the given formatter.