Expand description

Kafka consumers.

Modules

Low-level consumers.

High-level consumers with a Stream interface.

Structs

A low-level consumer that requires manual polling.

Consumer group metadata.

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

A stream of messages from a StreamConsumer.

A high-level consumer with a Stream interface.

Enums

Specifies whether a commit should be performed synchronously or asynchronously.

Rebalance information.

The rebalance protocol for a consumer.

Traits

Common trait for all consumers.

Consumer-specific context.