Expand description
Consumer group: decentralized partition assignment with lease-based liveness.
Each consumer in a group claims unclaimed or stale partitions from a shared
assignment map. Liveness is tracked via timestamps — if a consumer’s
heartbeat goes stale beyond stale_threshold_secs, its partitions are
eligible for rebalancing.
Structs§
- Consumer
Group - Shared state for a consumer group.