Expand description
Kafka consumers.
Modules§
- base_
consumer - Low-level consumers.
- stream_
consumer - High-level consumers with a
Streaminterface.
Structs§
- Base
Consumer - A low-level consumer that requires manual polling.
- Consumer
Group Metadata - Consumer group metadata.
- Default
Consumer Context - An inert
ConsumerContextthat can be used when no customizations are needed. - Message
Stream - A stream of messages from a
StreamConsumer. - Stream
Consumer - A high-level consumer with a
Streaminterface.
Enums§
- Commit
Mode - Specifies whether a commit should be performed synchronously or asynchronously.
- Rebalance
- Rebalance information.
- Rebalance
Protocol - The rebalance protocol for a consumer.
Traits§
- Consumer
- Common trait for all consumers.
- Consumer
Context - Consumer-specific context.