diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 289d909ba53ab60707d39c00bb11ac16fff9103b..fd43bac215925ab347d916d672e630fbbeca2cad 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()