Struct dataflow::sink::kafka::SinkProducerContext

pub struct SinkProducerContext {
    metrics: Arc<SinkMetrics>,
}

Fields

metrics: Arc<SinkMetrics>

Implementations

impl SinkProducerContext

pub fn new(metrics: Arc<SinkMetrics>) -> Self

Trait Implementations

impl ClientContext for SinkProducerContext

fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)

Receives log lines from librdkafka.

fn error(&self, error: KafkaError, reason: &str)

Receives global errors from the librdkafka client.

fn stats(&self, statistics: Statistics)

Receives the decoded statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified.

fn stats_raw(&self, statistics: &[u8])

Receives the JSON-encoded statistics of the librdkafka client. To enable, the statistics.interval.ms configuration parameter must be specified.

impl ProducerContext for SinkProducerContext

type DeliveryOpaque = ()

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.

fn delivery(&self, result: &DeliveryResult<'_>, _: 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.