Struct dataflow::source::kafka::GlueConsumerContext [−][src]
struct GlueConsumerContext {
activator: SyncActivator,
stats_tx: Sender<Jsonb>,
}
Expand description
An implementation of ConsumerContext
that forwards statistics to the
worker
Fields
activator: SyncActivator
stats_tx: Sender<Jsonb>
Implementations
Trait Implementations
Receives the JSON-encoded statistics of the librdkafka client. To
enable, the statistics.interval.ms
configuration parameter must be
specified. Read more
Receives log lines from librdkafka. Read more
Receives global errors from the librdkafka client. Read more
Receives the decoded statistics of the librdkafka client. To enable, the
statistics.interval.ms
configuration parameter must be specified. 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
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
Auto Trait Implementations
impl RefUnwindSafe for GlueConsumerContext
impl Send for GlueConsumerContext
impl Sync for GlueConsumerContext
impl Unpin for GlueConsumerContext
impl UnwindSafe for GlueConsumerContext
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