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_record<B: AsRef<[u8]>, '_>(
    &'_ self,
    buffer: B,
    partition: i32
) -> Result<(), FluvioError>

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

Example

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