zero4rs 2.0.0

zero4rs is a powerful, pragmatic, and extremely fast web framework for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use rdkafka::{producer::FutureProducer, ClientConfig};

// https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md
pub fn make_producer(settings: &super::KafkaSettings) -> FutureProducer {
    let mut config = ClientConfig::new();

    config.set("bootstrap.servers", settings.bootstrap_servers());

    config.set(
        "message.timeout.ms",
        format!("{}", settings.message_timeout_ms.unwrap()),
    );

    let l = config
        .create::<FutureProducer>()
        .expect("Producer creation error");

    log::info!("kafka-initialized-complete: bootstrap.servers={}", settings);

    l
}