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 = 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()