From b0653c0e9f3ef3c816e36323a9a7d1c2d632d3dd Mon Sep 17 00:00:00 2001
From: Bryan Stitt <bryan@llamanodes.com>
Date: Wed, 19 Apr 2023 15:30:01 -0700
Subject: [PATCH] add log for connecting to kafka

---
 web3_proxy/src/app/mod.rs | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/web3_proxy/src/app/mod.rs b/web3_proxy/src/app/mod.rs
index 2c095fdc..5041cd1d 100644
--- 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()