Module rdkafka::consumer [−] [src]

Base trait and common functionalities for all consumers.

Reexports

pub use consumer::base_consumer::BaseConsumer;

pub use topic_partition_list::TopicPartitionList;

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

CommitMode	Specifies if the commit should be performed synchronously or asynchronously.
Rebalance	Contains 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.