Expand description
Kafka consumer group rebalance state tracking.
RebalanceState tracks which topic-partitions are currently
assigned to this consumer and counts rebalance events.
LaminarConsumerContext is an rdkafka ConsumerContext that
signals a checkpoint request on partition revocation, enabling
the pipeline to persist offsets before ownership changes.
Structsยง
- Laminar
Consumer Context - rdkafka consumer context that signals a checkpoint on partition revocation.
- Rebalance
State - Tracks partition assignments across consumer group rebalances.