Struct KafkaProducer 

pub struct KafkaProducer { /* private fields */ }

Produces inventory records onto a Kafka topic.

Sends are non-blocking: records go onto librdkafka’s internal queue and a background thread delivers them. When that queue is full, Producer::send returns an error rather than waiting.

Implementations

impl KafkaProducer

pub fn try_new( config: KafkaConfig, on_delivery_failure: Option<OnDeliveryFailure>, ) -> Result<Self, KafkaProducerError>

Creates a producer from config, optionally reporting delivery failures to on_delivery_failure.

Failures are always logged. The callback is how a caller additionally counts them without this crate having to depend on a metrics backend.

Trait Implementations

impl Debug for KafkaProducer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Producer for KafkaProducer

type Error = KafkaProducerError

What can go wrong when sending.

fn send(&self, key: &[u8], payload: Vec<u8>) -> Result<(), Self::Error>

Enqueues one record.

fn join_blocking(&self, timeout: Duration) -> Result<(), Self::Error>

Blocks until enqueued records have been delivered, or timeout elapses.

fn shared(self) -> SharedProducer

where Self: Sized + Send + Sync + 'static, Self::Error: Error + Send + Sync + 'static,

Erases this producer’s transport and error type, so one producer can serve several trackers.