Struct fluvio::TopicProducer

pub struct TopicProducer { /* private fields */ }

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 flush(&self) -> Result<(), FluvioError>

Send all the queued records in the producer batches.

Example

producer.send("Key", "Value").await?;
producer.flush().await?;

pub async fn send<K, V>(
    &self,
    key: K,
    value: V
) -> Result<ProduceOutput, 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.

Depending on the producer configuration, a send call will not send immediately the record to the SPU. Instead, it could add the record to a batch. TopicProducer::flush is used to immediately send all the queued records in the producer batches.

Example

producer.send("Key", "Value").await?;

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

pub async fn clear_errors(&self)

Clear partition producers errors in order to make partition producers available. This is needed once an error is present in order to send new records again.