diff --git a/webservice/config/webservice.yaml b/webservice/config/webservice.yaml
index ffbbf0abc0efe169225d6690efa33462d7155364..0e23f1ca8bb889d82b84e5b097d5a2efcb419bb1 100644
--- a/webservice/config/webservice.yaml
+++ b/webservice/config/webservice.yaml
@@ -24,7 +24,7 @@ metadata-client:
 
 kafka:
   producer-config:
-    bootstrap-servers:
+    bootstrap_servers:
       - "exflwgs06.desy.de:9092"
     security_protocol: "SASL_PLAINTEXT"
     sasl_mechanism: "PLAIN"
diff --git a/webservice/job_monitor.py b/webservice/job_monitor.py
index 7ac62c4e57ae96b49a07f4a4c381ac5aa060e831..7947f004635fa723d614e506da01d0181e073098 100644
--- a/webservice/job_monitor.py
+++ b/webservice/job_monitor.py
@@ -46,7 +46,7 @@ def init_kafka_producer(config):
         return KafkaProducer(
             value_serializer=lambda d: json.dumps(d).encode('utf-8'),
             max_block_ms=2000,  # Don't get stuck trying to send Kafka messages
-            **config['kafka']['producer-config']
+            **config['kafka']['producer-config'].to_dict()
         )
     except KafkaError:
         log.warning("Problem initialising Kafka producer; "