Struct CustomContext

pub struct CustomContext;

Trait Implementations

impl ClientContext for CustomContext

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

Receives log lines from librdkafka.

fn stats(&self, statistics: Statistics)

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

fn stats_raw(&self, statistics: &[u8])

Receives the JSON-encoded 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 CustomContext

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.

fn commit_callback( &self, result: KafkaResult<()>, _offsets: &TopicPartitionList, )

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

fn rebalance( &self, native_client: &NativeClient, err: rd_kafka_resp_err_t, tpl: &mut 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 main_queue_min_poll_interval(&self) -> Timeout

Returns the minimum interval at which to poll the main queue, which services the logging, stats, and error callbacks.