Struct rdkafka::producer::base_producer::ThreadedProducer

pub struct ThreadedProducer<C> where
    C: ProducerContext + '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> ThreadedProducer<C> where
    C: ProducerContext + '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>>(&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> Drop for ThreadedProducer<C> where
    C: ProducerContext + 'static, 

fn drop(&mut self)

Executes the destructor for this type.

impl FromClientConfig for ThreadedProducer<DefaultProducerContext>

fn from_config(
    config: &ClientConfig
) -> KafkaResult<ThreadedProducer<DefaultProducerContext>>

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

impl<C> FromClientConfigAndContext<C> for ThreadedProducer<C> where
    C: ProducerContext + 'static, 

fn from_config_and_context(
    config: &ClientConfig,
    context: C
) -> KafkaResult<ThreadedProducer<C>>

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

impl<C> Producer<C> for ThreadedProducer<C> where
    C: ProducerContext + 'static, 

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

Returns the Client underlying this producer.

fn flush<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Flushes any pending messages.

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<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Enable sending transactions with this producer.

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

Begins a new transaction.

fn send_offsets_to_transaction<T: Into<Timeout>>(
    &self,
    offsets: &TopicPartitionList,
    cgm: &ConsumerGroupMetadata,
    timeout: T
) -> KafkaResult<()>

Associates an offset commit operation with this transaction.

fn commit_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Commits the current transaction.

fn abort_transaction<T: Into<Timeout>>(&self, timeout: T) -> KafkaResult<()>

Aborts the current transaction.

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

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