Struct mz_compute::sink::kafka::SinkProducerContext

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

Fields

metrics: Arc<SinkMetrics>

retry_manager: Arc<Mutex<KafkaSinkSendRetryManager>>

Implementations

impl SinkProducerContext

pub fn new(
    metrics: Arc<SinkMetrics>,
    retry_manager: Arc<Mutex<KafkaSinkSendRetryManager>>
) -> 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.

fn generate_oauth_token(
    &self,
    _oauthbearer_config: &str
) -> Result<OAuthTokenData, OAuthTokenError>

Generates the OAuth token.

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.