Skip to main content

Module group

Module group 

Source
Expand description

Classic consumer group alpha API.

Structs§

ConsumerGroup
Joined Kafka consumer group member.
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.

Enums§

ConsumerGroupAssignmentStrategy
Partition assignment strategy advertised by a classic consumer group member.
OffsetResetPolicy
Starting position used when an assigned partition has no committed offset.