add log for connecting to kafka

2023-04-19 15:30:01 -07:00 · 2023-04-19 15:30:01 -07:00 · b0653c0e9f
commit b0653c0e9f
parent 10d2d46512
1 changed files with 2 additions and 0 deletions
--- a/web3_proxy/src/app/mod.rs
+++ b/web3_proxy/src/app/mod.rs
@ -468,6 +468,8 @@ impl Web3ProxyApp {

        let mut kafka_producer: Option<rdkafka::producer::FutureProducer> = None;
        if let Some(kafka_brokers) = top_config.app.kafka_urls.clone() {
+            info!("Connecting to kafka");
+
            let security_protocol = &top_config.app.kafka_protocol;

            match rdkafka::ClientConfig::new()