Struct sea_streamer_kafka::KafkaProducerOptions

pub struct KafkaProducerOptions { /* private fields */ }

Implementations

impl KafkaProducerOptions

pub fn set_compression_type(&mut self, v: CompressionType) -> &mut Self

Set the compression method for this producer

pub fn compression_type(&self) -> Option<&CompressionType>

pub fn set_transaction_timeout(&mut self, v: Duration) -> &mut Self

Set the timeout used in all transactions for this producer

pub fn transaction_timeout(&self) -> Option<&Duration>

pub fn add_custom_option<K, V>(&mut self, key: K, value: V) -> &mut Self

where K: Into<String>, V: Into<String>,

Add a custom option. If you have an option you frequently use, please consider open a PR and add it to above.

pub fn custom_options(&self) -> impl Iterator<Item = (&str, &str)>

Trait Implementations

impl Clone for KafkaProducerOptions

fn clone(&self) -> KafkaProducerOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaProducerOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for KafkaProducerOptions

fn default() -> KafkaProducerOptions

Returns the “default value” for a type.

impl ProducerOptions for KafkaProducerOptions