Struct fluvio::TopicProducer

pub struct TopicProducer { /* fields omitted */ }

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

impl TopicProducer

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?;

pub async fn send_all<K, V, I>(&self, records: I) -> Result<(), FluvioError> where
    K: Into<RecordKey>,
    V: Into<RecordData>,
    I: IntoIterator<Item = (K, V)>, 

pub async fn send_record<B: AsRef<[u8]>>(
    &self,
    buffer: B,
    _partition: i32
) -> Result<(), FluvioError>

👎 Deprecated since 0.6.2:

Use ‘send’ instead

Sends an event to a specific partition within this producer’s topic

Example

let partition = 0;
producer.send_record("Hello, Fluvio!", partition).await?;