diff --git a/backend/deepchecks_monitoring/config.py b/backend/deepchecks_monitoring/config.py
index 784b97f6..d7c3a99d 100644
--- a/backend/deepchecks_monitoring/config.py
+++ b/backend/deepchecks_monitoring/config.py
@@ -66,7 +66,7 @@ class KafkaSettings(BaseDeepchecksSettings):
     kafka_username: t.Optional[str] = None
     kafka_password: t.Optional[str] = None
     kafka_replication_factor: int = 1
-    kafka_max_metadata_age: int = 60 * 1000
+    kafka_max_metadata_age: int = 300000
 
     @property
     def kafka_params(self):
diff --git a/backend/deepchecks_monitoring/logic/data_ingestion.py b/backend/deepchecks_monitoring/logic/data_ingestion.py
index 0a341939..a49098f0 100644
--- a/backend/deepchecks_monitoring/logic/data_ingestion.py
+++ b/backend/deepchecks_monitoring/logic/data_ingestion.py
@@ -347,7 +347,7 @@ def __init__(
         self.logger = logger or configure_logger(name="data-ingestion")
         self.use_kafka = self.resources_provider.kafka_settings.kafka_host is not None
         if self.use_kafka:
-            logging.getLogger("aiokafka.cluster").setLevel(logging.CRITICAL)
+            logging.getLogger("aiokafka.cluster").setLevel(logging.DEBUG)
 
     async def _send_with_retry(
             self,