Struct rdkafka_wrap::KWProducerConf

pub struct KWProducerConf {
    pub config: HashMap<String, String>,
    pub log_level: Option<RDKafkaLogLevel>,
    pub brokers: String,
    pub msg_timeout: Timeout,
    pub topic: Option<String>,
    pub num_partitions: i32,
    pub replication: i32,
}

Fields

config: HashMap<String, String>

log_level: Option<RDKafkaLogLevel>

brokers: String

msg_timeout: Timeout

topic: Option<String>

num_partitions: i32

replication: i32

Implementations

impl KWProducerConf

pub fn new<B>(brokers: B) -> Self

where B: AsRef<str>,

pub fn set_timeout<T: Into<Timeout>>(self, msg_timeout: T)

pub fn set_config<K, V>(self, config: HashMap<K, V>) -> Self

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

pub fn append_config<K, V>(self, key: K, value: V) -> Self

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

pub fn set_log_level(self, log_level: RDKafkaLogLevel) -> Self

pub fn set_topic_conf( self, topic: impl Into<String>, num_partitions: i32, replication: i32 ) -> Self

Trait Implementations

impl Debug for KWProducerConf

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

Formats the value using the given formatter.