Struct kafka_util::client::MzClientContext [−][src]
pub struct MzClientContext;
Expand description
A ClientContext
implementation that uses tracing
instead of log
macros.
All code in Materialize that constructs Kafka clients should use this context or
a custom context that delegates the log
and error
methods to this implementation.
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
A DeliveryOpaque
is a user-defined structure that will be passed to
the producer when producing a message, and returned to the delivery
method once the message has been delivered, or failed to. Read more
fn delivery(
&self,
delivery_result: &DeliveryResult<'_>,
delivery_opaque: Self::DeliveryOpaque
)
fn delivery(
&self,
delivery_result: &DeliveryResult<'_>,
delivery_opaque: Self::DeliveryOpaque
)
This method will be called once the message has been delivered (or
failed to). The DeliveryOpaque
will be the one provided by the user
when calling send. Read more
Auto Trait Implementations
impl RefUnwindSafe for MzClientContext
impl Send for MzClientContext
impl Sync for MzClientContext
impl Unpin for MzClientContext
impl UnwindSafe for MzClientContext
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