Struct rdkafka::producer::DefaultProducerContext
source · pub struct DefaultProducerContext;
Expand description
An inert producer context that can be used when customizations are not required.
Trait Implementations§
source§impl ClientContext for DefaultProducerContext
impl ClientContext for DefaultProducerContext
source§const ENABLE_REFRESH_OAUTH_TOKEN: bool = false
const ENABLE_REFRESH_OAUTH_TOKEN: bool = false
Whether to periodically refresh the SASL
OAUTHBEARER
token
by calling ClientContext::generate_oauth_token
. Read moresource§fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)
Receives log lines from librdkafka. Read more
source§fn stats(&self, statistics: Statistics)
fn stats(&self, statistics: Statistics)
Receives the decoded statistics of the librdkafka client. To enable, the
statistics.interval.ms
configuration parameter must be specified. Read moresource§fn stats_raw(&self, statistics: &[u8])
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. Read moresource§fn error(&self, error: KafkaError, reason: &str)
fn error(&self, error: KafkaError, reason: &str)
Receives global errors from the librdkafka client. Read more
source§fn rewrite_broker_addr(&self, addr: BrokerAddr) -> BrokerAddr
fn rewrite_broker_addr(&self, addr: BrokerAddr) -> BrokerAddr
Rewrites a broker address for DNS resolution. Read more
source§fn generate_oauth_token(
&self,
_oauthbearer_config: Option<&str>
) -> Result<OAuthToken, Box<dyn Error>>
fn generate_oauth_token(
&self,
_oauthbearer_config: Option<&str>
) -> Result<OAuthToken, Box<dyn Error>>
Generates an OAuth token from the provided configuration. Read more
source§impl Clone for DefaultProducerContext
impl Clone for DefaultProducerContext
source§fn clone(&self) -> DefaultProducerContext
fn clone(&self) -> DefaultProducerContext
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl ProducerContext for DefaultProducerContext
impl ProducerContext for DefaultProducerContext
§type DeliveryOpaque = ()
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.source§fn delivery(&self, _: &DeliveryResult<'_>, _: Self::DeliveryOpaque)
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.