Module rdkafka::consumer

Kafka consumers.

Re-exports

pub use self::base_consumer::BaseConsumer;

pub use self::stream_consumer::MessageStream;

pub use self::stream_consumer::StreamConsumer;

Modules

base_consumer	Low level consumer wrapper.
stream_consumer	Stream-based consumer implementation.

Structs

DefaultConsumerContext

An empty consumer context that can be user when no customizations are needed.

Enums

CommitMode	Specifies if the commit should be performed synchronously or asynchronously.
Rebalance	Rebalance information.

Traits

Consumer	Common trait for all consumers.
ConsumerContext	Consumer-specific context.