Module group 

Classic consumer group alpha API.

Re-exports

pub use crate::consumer::OffsetResetPolicy;

Structs

ConsumerGroup

Joined Kafka consumer group member.

ConsumerGroupCommitWorker

Handle for a bounded background consumer-group offset commit task.

ConsumerGroupConfig

Configuration builder for the classic Kafka consumer group alpha API.

ConsumerGroupHeartbeat

Handle for a background consumer group heartbeat task.

ConsumerGroupMetadata

Consumer group identity used to fence transactional offset commits.

RebalanceEvent

Snapshot delivered to a consumer-group rebalance listener.

Enums

ConsumerGroupAssignmentStrategy

Partition assignment strategy advertised by a classic consumer group member.

ConsumerGroupProtocol

Consumer group membership protocol used by a group member.

RebalancePhase

Phase of a consumer-group rebalance callback.

Traits

RebalanceListener

Receives synchronous notifications when a consumer-group assignment changes.