kafka_io/
client.rs

1use rdkafka::config::{ClientConfig, RDKafkaLogLevel};
2
3pub fn config(group_id: &str, brokers: Vec<&str>, log_level: RDKafkaLogLevel) -> ClientConfig {
4    ClientConfig::new()
5        .set("group.id", group_id)
6        .set("debug", "all")
7        .set("bootstrap.servers", brokers.join(",").as_str())
8        .set("enable.partition.eof", "false")
9        .set("session.timeout.ms", "6000")
10        .set("auto.offset.reset", "smallest")
11        .set_log_level(log_level)
12        .to_owned()
13}