test-kafka-debug (#383)

Author: JKL98ISR

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):

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,