[−][src]Module rdkafka::consumer

Base trait and common functionality for all consumers.

Re-exports

pub use self::base_consumer::BaseConsumer;

pub use self::stream_consumer::MessageStream;

pub use self::stream_consumer::StreamConsumer;

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

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

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

Consumer	Common trait for all consumers.
ConsumerContext	Consumer specific Context. This user-defined object can be used to provide custom callbacks to consumer events. Refer to the list of methods to check which callbacks can be specified.