1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

use rdkafka::config::{ClientConfig, RDKafkaLogLevel};

pub fn config(group_id: &str, brokers: Vec<&str>, log_level: RDKafkaLogLevel) -> ClientConfig {
    ClientConfig::new()
        .set("group.id", group_id)
        .set("debug", "all")
        .set("bootstrap.servers", brokers.join(",").as_str())
        .set("enable.partition.eof", "false")
        .set("session.timeout.ms", "6000")
        .set("auto.offset.reset", "smallest")
        .set_log_level(log_level)
        .to_owned()
}