Struct rdkafka_wrap::KWConsumerConf

pub struct KWConsumerConf {
    pub config: HashMap<String, String>,
    pub log_level: Option<RDKafkaLogLevel>,
    pub group_id: String,
    pub brokers: String,
    pub topics: Vec<String>,
}

Fields

config: HashMap<String, String>

log_level: Option<RDKafkaLogLevel>

group_id: String

brokers: String

topics: Vec<String>

Implementations

impl KWConsumerConf

pub fn new(brokers: &str, group_id: &str) -> Self

pub fn set_topics<I, T>(self, topics: T) -> Selfwhere I: AsRef<str>, T: IntoIterator<Item = I>,

pub fn set_config<K, V>(self, config: HashMap<K, V>) -> Selfwhere K: Into<String>, V: Into<String>,

pub fn append_config<K, V>(self, key: K, value: V) -> Selfwhere K: Into<String>, V: Into<String>,

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