Struct fluvio::TopicProducer [−][src]
pub struct TopicProducer { /* fields omitted */ }
Expand description
An interface for producing events to a particular topic
A TopicProducer
allows you to send events to the specific
topic it was initialized for. Once you have a TopicProducer
,
you can send events to the topic, choosing which partition
each event should be delivered to.
Implementations
pub async fn send<K, V>(&self, key: K, value: V) -> Result<(), FluvioError> where
K: Into<RecordKey>,
V: Into<RecordData>,
pub async fn send<K, V>(&self, key: K, value: V) -> Result<(), FluvioError> where
K: Into<RecordKey>,
V: Into<RecordData>,
Sends a key/value record to this producer’s Topic.
The partition that the record will be sent to is derived from the Key.
Example
producer.send("Key", "Value").await?;