Trait rdkafka::consumer::Consumer

pub trait Consumer {
    fn get_base_consumer(&self) -> &BaseConsumer;
    fn get_base_consumer_mut(&mut self) -> &mut BaseConsumer;

    fn subscribe(&mut self, topics: &Vec<&str>) -> KafkaResult<()> { ... }
    fn commit_message(&self, message: &Message, mode: CommitMode) { ... }
}

Common trait for all consumers

Required Methods

fn get_base_consumer(&self) -> &BaseConsumer

Returns a reference to the BaseConsumer.

fn get_base_consumer_mut(&mut self) -> &mut BaseConsumer

Returns a mutable reference to the BaseConsumer.

Provided Methods

fn subscribe(&mut self, topics: &Vec<&str>) -> KafkaResult<()>

Subscribe the consumer to a list of topics.

fn commit_message(&self, message: &Message, mode: CommitMode)

Commit a specific message. If mode is set to CommitMode::Sync, the call will block until the message has been succesfully committed.

Implementors

• impl Consumer for BaseConsumer
• impl Consumer for StreamConsumer