3 docs tagged with "consumer-groups"

How Rafka consumer groups work: cgp_<ULID> entity identity, durable offsets on the WAL (P3.B), the single-member protocol, and ephemeral session vs durable offset state.

Use confluent-kafka Consumer groups to subscribe to topics, consume records, and resume from a committed offset across client sessions — offsets survive broker restarts (P3.B).

Broker GroupCoordinator internals: durable offsets via SingleWal (P3.B), state machine, KafkaOp 0x06-0x0B, FindCoordinator gateway-local, rebalance oneshot, recovery scan, and spans.