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 resolve_broker_addr(
&self,
host: &str,
port: u16,
) -> Result<Vec<SocketAddr>, Error>
fn resolve_broker_addr( &self, host: &str, port: u16, ) -> Result<Vec<SocketAddr>, Error>
Performs DNS resolution on a broker address. 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.Auto Trait Implementations§
impl Freeze for DefaultProducerContext
impl RefUnwindSafe for DefaultProducerContext
impl Send for DefaultProducerContext
impl Sync for DefaultProducerContext
impl Unpin for DefaultProducerContext
impl UnwindSafe for DefaultProducerContext
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)