Struct sql::kafka_util::KafkaErrCheckContext [−][src]
Expand description
Gets error strings from rdkafka
when creating test consumers.
Fields
error: Mutex<Option<String>>
Trait Implementations
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
Pre-rebalance callback. This method will run before the rebalance and should terminate its execution quickly. Read more
Post-rebalance callback. This method will run after the rebalance and should terminate its execution quickly. 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
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl RefUnwindSafe for KafkaErrCheckContext
impl Send for KafkaErrCheckContext
impl Sync for KafkaErrCheckContext
impl Unpin for KafkaErrCheckContext
impl UnwindSafe for KafkaErrCheckContext
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more