Struct ThreadedProducer

pub struct ThreadedProducer<C, Part: Partitioner = NoCustomPartitioner>
where
    C: ProducerContext<Part> + 'static,
{ /* private fields */ }

A low-level Kafka producer with a separate thread for event handling.

The ThreadedProducer is a BaseProducer with a separate thread dedicated to calling poll at regular intervals in order to execute any queued events, such as delivery notifications. The thread will be automatically stopped when the producer is dropped.

Implementations

impl<C, Part> ThreadedProducer<C, Part>

where Part: Partitioner, C: ProducerContext<Part> + 'static,

pub fn send<'a, K, P>( &self, record: BaseRecord<'a, K, P, C::DeliveryOpaque>, ) -> Result<(), (KafkaError, BaseRecord<'a, K, P, C::DeliveryOpaque>)>

where K: ToBytes + ?Sized, P: ToBytes + ?Sized,

Sends a message to Kafka.

See the documentation for BaseProducer::send for details.

pub fn poll<T: Into<Timeout> + Send>(&self, timeout: T)

Polls the internal producer.

This is not normally required since the ThreadedProducer has a thread dedicated to calling poll regularly.

Trait Implementations

impl<C, Part> Drop for ThreadedProducer<C, Part>

where Part: Partitioner, C: ProducerContext<Part> + 'static,

fn drop(&mut self)

Executes the destructor for this type.

impl FromClientConfig for ThreadedProducer<DefaultProducerContext, NoCustomPartitioner>

fn from_config<'life0, 'async_trait>( config: &'life0 ClientConfig, ) -> Pin<Box<dyn Future<Output = KafkaResult<ThreadedProducer<DefaultProducerContext>>> + Send + 'async_trait>>

where 'life0: 'async_trait,

Creates a client from a client configuration. The default client context will be used.

impl<C, Part> FromClientConfigAndContext<C> for ThreadedProducer<C, Part>

where Part: Partitioner + Send + Sync + 'static, C: ProducerContext<Part> + 'static,

fn from_config_and_context<'life0, 'async_trait>( config: &'life0 ClientConfig, context: C, ) -> Pin<Box<dyn Future<Output = KafkaResult<ThreadedProducer<C, Part>>> + Send + 'async_trait>>

where 'life0: 'async_trait,

Creates a client from a client configuration and a client context.

impl<C, Part> Producer<C, Part> for ThreadedProducer<C, Part>

where Part: Partitioner, C: ProducerContext<Part> + 'static,

fn client(&self) -> &Client<C>

Returns the Client underlying this producer.

fn flush<'life0, 'async_trait, T>( &'life0 self, timeout: T, ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>

where T: 'async_trait + Into<Timeout> + Send, Self: 'async_trait, 'life0: 'async_trait,

Flushes any pending messages.

fn purge(&self, flags: PurgeConfig)

Purge messages currently handled by the producer instance.

fn in_flight_count(&self) -> i32

Returns the number of messages that are either waiting to be sent or are sent but are waiting to be acknowledged.

fn init_transactions<'life0, 'async_trait, T>( &'life0 self, timeout: T, ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>

where T: 'async_trait + Into<Timeout> + Send, Self: 'async_trait, 'life0: 'async_trait,

Enable sending transactions with this producer.

fn begin_transaction(&self) -> KafkaResult<()>

Begins a new transaction.

fn send_offsets_to_transaction<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 self, offsets: &'life1 TopicPartitionList, cgm: &'life2 ConsumerGroupMetadata, timeout: T, ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>

where T: 'async_trait + Into<Timeout> + Send, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Associates an offset commit operation with this transaction.

fn commit_transaction<'life0, 'async_trait, T>( &'life0 self, timeout: T, ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>

where T: 'async_trait + Into<Timeout> + Send, Self: 'async_trait, 'life0: 'async_trait,

Commits the current transaction.

fn abort_transaction<'life0, 'async_trait, T>( &'life0 self, timeout: T, ) -> Pin<Box<dyn Future<Output = KafkaResult<()>> + Send + 'async_trait>>

where T: 'async_trait + Into<Timeout> + Send, Self: 'async_trait, 'life0: 'async_trait,

Aborts the current transaction.

fn context(&self) -> &Arc<C>

Returns a reference to the ProducerContext used to create this producer.