Struct rdkafka::consumer::EmptyConsumerContext

pub struct EmptyConsumerContext;

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

Trait Implementations

impl Clone for EmptyConsumerContext

fn clone(&self) -> EmptyConsumerContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Context for EmptyConsumerContext

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.

impl ConsumerContext for EmptyConsumerContext

fn rebalance(&self,
             native_client: &NativeClient,
             err: RDKafkaRespErr,
             partitions_ptr: *mut RDKafkaTopicPartitionList)

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(&self, _rebalance: &Rebalance)

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

fn post_rebalance(&self, _rebalance: &Rebalance)

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