Struct AsyncProducer 

pub struct AsyncProducer { /* private fields */ }

An async Kafka producer.

This producer always uses native async I/O via tokio sockets.

Implementations

impl AsyncProducer

pub fn builder(hosts: Vec<String>) -> AsyncProducerBuilder

Starts building a new async producer from bootstrap hosts.

pub async fn new(client: AsyncKafkaClient) -> Result<Self>

Creates a new async producer from an AsyncKafkaClient.

pub async fn new_with_config( client: AsyncKafkaClient, config: AsyncProducerConfig, ) -> Result<Self>

Creates a new async producer with explicit configuration.

pub async fn from_hosts(hosts: Vec<String>) -> Result<Self>

Creates a new async producer directly from bootstrap hosts.

pub async fn from_hosts_with_config( hosts: Vec<String>, config: AsyncProducerConfig, ) -> Result<Self>

Creates a new async producer from hosts with explicit configuration.

pub async fn send<K, V>(&self, record: &Record<'_, K, V>) -> Result<()>

where K: AsBytes, V: AsBytes,

Sends a message to Kafka asynchronously.

pub async fn flush(&self) -> Result<()>

Flushes any pending messages.

pub async fn close(self) -> Result<()>

Gracefully shuts down the producer.