Struct fluvio::TopicProducerConfigBuilder

pub struct TopicProducerConfigBuilder { /* private fields */ }

Builder for TopicProducerConfig.

Implementations

impl TopicProducerConfigBuilder

pub fn batch_size(self, value: usize) -> Self

Maximum amount of bytes accumulated by the records before sending the batch.

pub fn linger(self, value: Duration) -> Self

Time to wait before sending messages to the server.

pub fn partitioner(self, value: Box<dyn Partitioner + Send + Sync>) -> Self

Partitioner assigns the partition to each record that needs to be send

pub fn compression<VALUE: Into<Compression>>(self, value: VALUE) -> Self

Compression algorithm used by Fluvio producer to compress data. If there is a topic level compression and it is not compatible with this setting, the producer initialization will fail.

pub fn timeout(self, value: Duration) -> Self

Max time duration that the server is allowed to process the batch.

pub fn isolation(self, value: Isolation) -> Self

Isolation level that the producer must respect. Isolation::ReadCommitted waits for messages to be committed (replicated) before sending the response to the caller. Isolation::ReadUncommitted just waits for the leader to accept the message.

pub fn build(
    self
) -> Result<TopicProducerConfig, TopicProducerConfigBuilderError>

Builds a new TopicProducerConfig.

Errors

If a required field has not been initialized.

Trait Implementations

impl Default for TopicProducerConfigBuilder

fn default() -> Self

Returns the “default value” for a type.