Struct Producer

pub struct Producer<P = DefaultPartitioner> { /* private fields */ }

The Kafka Producer

See module level documentation.

Implementations

impl Producer

pub fn from_client(client: KafkaClient) -> Builder<DefaultPartitioner>

Starts building a new producer using the given Kafka client.

pub fn from_hosts(hosts: Vec<String>) -> Builder<DefaultPartitioner>

Starts building a producer bootstraping internally a new kafka client from the given kafka hosts.

pub fn client(&self) -> &KafkaClient

Borrows the underlying kafka client.

pub fn client_mut(&mut self) -> &mut KafkaClient

Borrows the underlying kafka client as mut.

pub fn into_client(self) -> KafkaClient

Destroys this producer returning the underlying kafka client.

impl<P: Partitioner> Producer<P>

pub fn send<'a, K, V>(&mut self, rec: &Record<'a, K, V>) -> Result<()>

where K: AsBytes, V: AsBytes,

Synchronously send the specified message to Kafka.

pub fn send_all<'a, K, V>( &mut self, recs: &[Record<'a, K, V>], ) -> Result<Vec<ProduceConfirm>>

where K: AsBytes, V: AsBytes,

Synchronously send all of the specified messages to Kafka. To validate that all of the specified records have been successfully delivered, inspection of the offsets on the returned confirms is necessary.