Module base_
consumer
rdkafka
0.29.0
Module base_
consumer
Module Items
Structs
In rdkafka::
consumer
Modules
base_consumer
stream_consumer
Structs
BaseConsumer
ConsumerGroupMetadata
DefaultConsumerContext
MessageStream
StreamConsumer
Enums
CommitMode
Rebalance
RebalanceProtocol
Traits
Consumer
ConsumerContext
rdkafka
::
consumer
Module
base_consumer
Copy item path
Settings
Help
Summary
Source
Expand description
Low-level consumers.
Structs
§
Base
Consumer
A low-level consumer that requires manual polling.
Iter
A convenience iterator over the messages in a
BaseConsumer
.
Partition
Queue
A message queue for a single partition.