Struct rdkafka::consumer::DefaultConsumerContext

pub struct DefaultConsumerContext;

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

Trait Implementations

impl Clone for DefaultConsumerContext

fn clone(&self) -> DefaultConsumerContext

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ClientContext for DefaultConsumerContext

fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)

Receives log lines from librdkafka.

fn stats(&self, statistics: Statistics)

Receives the statistics of the librdkafka client. To enable, the "statistics.interval.ms" configuration parameter must be specified.

fn error(&self, error: KafkaError, reason: &str)

Receives global errors from the librdkafka client.

impl ConsumerContext for DefaultConsumerContext

fn rebalance(
    &self,
    native_client: &NativeClient,
    err: RDKafkaRespErr,
    tpl: &TopicPartitionList
)

Implements the default rebalancing strategy and calls the pre_rebalance and post_rebalance methods. If this method is overridden, it will be responsibility of the user to call them if needed.

fn pre_rebalance<'a>(&self, rebalance: &Rebalance<'a>)

Pre-rebalance callback. This method will run before the rebalance and should terminate its execution quickly.

fn post_rebalance<'a>(&self, rebalance: &Rebalance<'a>)

Post-rebalance callback. This method will run after the rebalance and should terminate its execution quickly.

fn commit_callback(
    &self,
    result: KafkaResult<()>,
    offsets: *mut RDKafkaTopicPartitionList
)

Post commit callback. This method will run after a group of offsets was committed to the offset store.