Struct DefaultProducerContext

pub struct DefaultProducerContext;

An inert producer context that can be used when customizations are not required.

Trait Implementations

impl ClientContext for DefaultProducerContext

fn enable_refresh_oauth_token(&self) -> bool

Whether to periodically refresh the SASL OAUTHBEARER token by calling ClientContext::generate_oauth_token.

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

Receives log lines from librdkafka.

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 error(&self, error: KafkaError, reason: &str)

Receives global errors from the librdkafka client.

fn rewrite_broker_addr(&self, addr: BrokerAddr) -> BrokerAddr

Rewrites a broker address for DNS resolution.

fn generate_oauth_token( &self, _oauthbearer_config: Option<&str>, ) -> Result<OAuthToken, Box<dyn Error>>

Generates an OAuth token from the provided configuration.

impl Clone for DefaultProducerContext

fn clone(&self) -> DefaultProducerContext

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ProducerContext for DefaultProducerContext

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, _: &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.

fn get_custom_partitioner(&self) -> Option<&Part>

This method is called when creating producer in order to optionally register custom partitioner. If custom partitioner is not used then partitioner configuration property is used (or its default).