From 0845d4502fe49fd30c1406c63f4c2324ed1ec3cf Mon Sep 17 00:00:00 2001
From: Thomas Kluyver <thomas@kluyver.me.uk>
Date: Tue, 24 May 2022 17:27:39 +0100
Subject: [PATCH] Set info logging level for kafka module
---
webservice/job_monitor.py | 2 ++
1 file changed, 2 insertions(+)
diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 289d909ba..fd43bac21 100644
--- a/webservice/job_monitor.py
+++ b/webservice/job_monitor.py
@@ -319,6 +319,8 @@ def main(argv=None):
level=getattr(logging, args.log_level),
format=fmt
)
+ # DEBUG logs from kafka-python are very verbose, so we'll turn them off
+ logging.getLogger('kafka').setLevel(logging.INFO)
JobsMonitor(config).run()
--
GitLab