diff --git a/Cargo.lock b/Cargo.lock
index 50850b1c5d..5510d069b1 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3810,9 +3810,9 @@ dependencies = [
 
 [[package]]
 name = "log"
-version = "0.4.21"
+version = "0.4.22"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "90ed8c1e510134f979dbc4f070f87d4313098b704861a105fe34231c70a3901c"
+checksum = "a7a70ba024b9dc04c27ea2f0c0548feb474ec5c54bba33a7f72f873a39d07b24"
 dependencies = [
  "serde",
  "value-bag",
diff --git a/tremor-connectors-azure/Cargo.toml b/tremor-connectors-azure/Cargo.toml
index 0ccf8c410f..9fa976b452 100644
--- a/tremor-connectors-azure/Cargo.toml
+++ b/tremor-connectors-azure/Cargo.toml
@@ -28,7 +28,7 @@ async-trait = "0.1.81"
 url = "2.5.2"
 reqwest = { version = "0.12.4", default-features = false, features = ["json"] }
 tokio = "1.39.2"
-log = "0.4.21"
+log = "0.4.22"
 tremor-script = { version = "0.13.0-rc.29", path = "../tremor-script" }
 bytes = "1.6.1"
 futures = { version = "0.3.30", default-features = false, features = [
diff --git a/tremor-connectors/src/impls/kafka.rs b/tremor-connectors/src/impls/kafka.rs
index 088cbc0c89..963d5e4e60 100644
--- a/tremor-connectors/src/impls/kafka.rs
+++ b/tremor-connectors/src/impls/kafka.rs
@@ -497,10 +497,7 @@ where
             rdkafka::config::RDKafkaLogLevel::Warning => {
                 warn!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message);
             }
-            rdkafka::config::RDKafkaLogLevel::Notice => {
-                info!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message);
-            }
-            rdkafka::config::RDKafkaLogLevel::Info => {
+            rdkafka::config::RDKafkaLogLevel::Notice | rdkafka::config::RDKafkaLogLevel::Info => {
                 info!(target: "librdkafka", "{} librdkafka: {} {}", self.ctx, fac, log_message);
             }
             rdkafka::config::RDKafkaLogLevel::Debug => {
diff --git a/tremor-connectors/src/lib.rs b/tremor-connectors/src/lib.rs
index e13d5d5e8d..dffcf4addd 100644
--- a/tremor-connectors/src/lib.rs
+++ b/tremor-connectors/src/lib.rs
@@ -692,7 +692,7 @@ async fn connector_task(
                     info!("{ctx} Ignoring SourceDrained Msg. Current state: {connector_state}",);
                 }
                 Msg::SinkDrained => {
-                    info!("{ctx} Ignoring SourceDrained Msg. Current state: {connector_state}",);
+                    info!("{ctx} Ignoring SinkDrained Msg. Current state: {connector_state}",);
                 }
                 Msg::Stop(sender) => {
                     info!("{ctx} Stopping...");