Module consumer

Kafka consumers.

Modules

base_consumer

Low-level consumers.

stream_consumer

High-level consumers with a Stream interface.

Structs

BaseConsumer

A low-level consumer that requires manual polling.

ConsumerGroupMetadata

Consumer group metadata.

DefaultConsumerContext

An inert ConsumerContext that can be used when no customizations are needed.

MessageStream

A stream of messages from a StreamConsumer.

StreamConsumer

A high-level consumer with a Stream interface.

Enums

CommitMode

Specifies whether a commit should be performed synchronously or asynchronously.

Rebalance

Rebalance information.

RebalanceProtocol

The rebalance protocol for a consumer.

Traits

Consumer

Common trait for all consumers.

ConsumerContext

Consumer-specific context.