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 batch_queue_size(self, value: usize) -> Self

Maximum amount of batches waiting in the queue before sending to the SPU.

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 delivery_semantic(self, value: DeliverySemantic) -> Self

Delivery guarantees that producer must respect. DeliverySemantic::AtMostOnce - send records without waiting from response. Fire and forget approach. DeliverySemantic::AtLeastOnce - send records, wait for the response and retry if error occurred. Retry parameters, such as delay, retry strategy, timeout, etc., can be configured in RetryPolicy.

pub fn smartmodules(self, value: Vec<SmartModuleInvocation>) -> Self

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.