From 61d1829edbcd09f7fd2387f996dffd8b6192f328 Mon Sep 17 00:00:00 2001
From: Thomas Kluyver <thomas.kluyver@xfel.eu>
Date: Wed, 24 Jan 2024 12:37:31 +0100
Subject: [PATCH] Fix passing Kakfa producer config
---
webservice/config/webservice.yaml | 2 +-
webservice/job_monitor.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/webservice/config/webservice.yaml b/webservice/config/webservice.yaml
index ffbbf0abc..0e23f1ca8 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 7ac62c4e5..7947f0046 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; "
--
GitLab