[−][src]Struct rdkafka::producer::base_producer::DefaultProducerContext
Default producer context that can be use when a custom context is not required.
Trait Implementations
impl ClientContext for DefaultProducerContext[src]
fn log(&self, level: RDKafkaLogLevel, fac: &str, log_message: &str)[src]
Receives log lines from librdkafka.
fn stats(&self, statistics: Statistics)[src]
Receives the statistics of the librdkafka client. To enable, the "statistics.interval.ms" configuration parameter must be specified. Read more
fn error(&self, error: KafkaError, reason: &str)[src]
Receives global errors from the librdkafka client.
impl ProducerContext for DefaultProducerContext[src]
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. Read more
fn delivery(&self, _: &DeliveryResult, _: Self::DeliveryOpaque)[src]
impl Clone for DefaultProducerContext[src]
fn clone(&self) -> DefaultProducerContext[src]
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl Send for DefaultProducerContext
impl Sync for DefaultProducerContext
Blanket Implementations
impl<T> From for T[src]
impl<T, U> Into for T where
U: From<T>, [src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone, [src]
T: Clone,
impl<T, U> TryFrom for T where
U: Into<T>, [src]
U: Into<T>,
type Error = !
🔬 This is a nightly-only experimental API. (
try_from)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T> Borrow for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T, U> TryInto for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,