Struct replicator::config::ConsumerTestContext

pub struct ConsumerTestContext {
    pub _n: i64,
    pub wakeups: Arc<AtomicUsize>,
}

Fields

_n: i64

wakeups: Arc<AtomicUsize>

Trait Implementations

impl ClientContext for ConsumerTestContext

pub fn stats(&self, stats: Statistics)

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

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

Receives log lines from librdkafka.

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

Receives global errors from the librdkafka client.

impl ConsumerContext for ConsumerTestContext

pub 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.

pub fn message_queue_nonempty_callback(&self)

Message queue nonempty callback. This method will run when the consumer's message queue switches from empty to nonempty.

pub 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.

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

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

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

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

pub 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.