Struct r_neli::NeliConsumerContext [−][src]
pub struct NeliConsumerContext<F> where
F: FnMut(Vec<LeaderEvent>) + Send + Sync, { /* fields omitted */ }
Trait Implementations
impl<F> ClientContext for NeliConsumerContext<F> where
F: FnMut(Vec<LeaderEvent>) + Send + Sync,
impl<F> ClientContext for NeliConsumerContext<F> where
F: FnMut(Vec<LeaderEvent>) + Send + Sync,
Receives log lines from librdkafka. Read more
Receives the decoded statistics of the librdkafka client. To enable, the
statistics.interval.ms
configuration parameter must be specified. Read more
Receives the JSON-encoded statistics of the librdkafka client. To
enable, the statistics.interval.ms
configuration parameter must be
specified. Read more
Receives global errors from the librdkafka client. Read more
impl<F> ConsumerContext for NeliConsumerContext<F> where
F: FnMut(Vec<LeaderEvent>) + Send + Sync,
impl<F> ConsumerContext for NeliConsumerContext<F> where
F: FnMut(Vec<LeaderEvent>) + Send + Sync,
Post-rebalance callback. This method will run after the rebalance and should terminate its execution quickly. Read more
Pre-rebalance callback. This method will run before the rebalance and should terminate its execution quickly. Read more
fn rebalance(
&self,
native_client: &NativeClient,
err: rd_kafka_resp_err_t,
tpl: &mut TopicPartitionList
)
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. Read more
Post commit callback. This method will run after a group of offsets was committed to the offset store. Read more
Returns the minimum interval at which to poll the main queue, which services the logging, stats, and error callbacks. Read more