Struct Producer 

pub struct Producer { /* private fields */ }

A producer that sends messages to a named topic.

Implementations

impl Producer

pub fn new(topic_name: &str) -> Self

Create a new producer for the named topic.

pub fn with_partitioner(self, p: Partitioner) -> Self

Set the partitioning strategy.

pub fn send(&mut self, mgr: &mut TopicManager, value: &[u8]) -> Result<u64>

Send a message without a key (uses round-robin partitioning).

pub fn send_keyed( &mut self, mgr: &mut TopicManager, key: &[u8], value: &[u8], ) -> Result<u64>

Send a keyed message.

With Partitioner::KeyHash, the key determines the partition. With Partitioner::RoundRobin, the key is stored but partition selection still uses round-robin.

pub fn send_to( &mut self, mgr: &mut TopicManager, partition: u32, key: Option<&[u8]>, value: &[u8], ) -> Result<u64>

Send a message to a specific partition.