Skip to main content

Module rebalance

Module rebalance 

Source
Expand description

Kafka consumer group rebalance state tracking.

RebalanceState tracks which topic-partitions are currently assigned to this consumer.

LaminarConsumerContext is an rdkafka ConsumerContext that tracks assignment changes and broker offset-commit outcomes.

Structsยง

LaminarConsumerContext
rdkafka consumer context that tracks partition assignment changes.
RebalanceState
Tracks partition assignments across consumer group rebalances.