Struct rdkafka_wrap::KWConsumerConf

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

Fields

config: HashMap<String, String>

log_level: Option<RDKafkaLogLevel>

group_id: GroupID

brokers: String

topics: Vec<String>

Implementations

impl KWConsumerConf

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

where B: AsRef<str>, G: AsRef<str>,

pub fn set_topics<I, T>(self, topics: T) -> Self

where I: AsRef<str>, T: IntoIterator<Item = I>,

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

Trait Implementations

impl Debug for KWConsumerConf

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

Formats the value using the given formatter.