Struct TopicProducerConfig

pub struct TopicProducerConfig { /* private fields */ }

Options used to adjust the behavior of the Producer. Create this struct with TopicProducerConfigBuilder.

Create a producer with a custom config with crate::Fluvio::topic_producer_with_config().

Implementations

impl TopicProducerConfig

pub fn linger(&self) -> Duration

pub fn batch_size(&self) -> usize

pub fn max_request_size(&self) -> usize

pub fn batch_queue_size(&self) -> usize

pub fn compression(&self) -> Option<Compression>

pub fn timeout(&self) -> Duration

pub fn isolation(&self) -> Isolation

pub fn delivery_semantic(&self) -> DeliverySemantic

pub fn smartmodules(&self) -> &Vec<SmartModuleInvocation>

Trait Implementations

impl Default for TopicProducerConfig

fn default() -> Self

Returns the “default value” for a type.