[−][src]Struct rdkafka::consumer::DefaultConsumerContext
An empty consumer context that can be user when no context is needed.
Trait Implementations
impl ClientContext for DefaultConsumerContext
[src]
fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
[src]
Receives log lines from librdkafka.
fn stats(&self, statistics: Statistics)
[src]
Receives the statistics of the librdkafka client. To enable, the "statistics.interval.ms" configuration parameter must be specified. Read more
fn error(&self, error: KafkaError, reason: &str)
[src]
Receives global errors from the librdkafka client.
impl ConsumerContext for DefaultConsumerContext
[src]
fn rebalance(
&self,
native_client: &NativeClient,
err: RDKafkaRespErr,
tpl: &mut TopicPartitionList
)
[src]
&self,
native_client: &NativeClient,
err: RDKafkaRespErr,
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
fn pre_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
[src]
Pre-rebalance callback. This method will run before the rebalance and should terminate its execution quickly. Read more
fn post_rebalance<'a>(&self, rebalance: &Rebalance<'a>)
[src]
Post-rebalance callback. This method will run after the rebalance and should terminate its execution quickly. Read more
fn commit_callback(
&self,
result: KafkaResult<()>,
offsets: *mut RDKafkaTopicPartitionList
)
[src]
&self,
result: KafkaResult<()>,
offsets: *mut RDKafkaTopicPartitionList
)
Post commit callback. This method will run after a group of offsets was committed to the offset store. Read more
impl Clone for DefaultConsumerContext
[src]
fn clone(&self) -> DefaultConsumerContext
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
Performs copy-assignment from source
. Read more
Auto Trait Implementations
impl Send for DefaultConsumerContext
impl Sync for DefaultConsumerContext
Blanket Implementations
impl<T> From for T
[src]
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
impl<T, U> TryFrom for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,