Commit 49dacb33 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Try fix for class global Kafka Producer.

parent 2a3ce60d
Pipeline #26152 passed with stages
in 2 minutes and 14 seconds
......@@ -11,7 +11,9 @@ from requests.auth import HTTPBasicAuth
class UpdateRecordSet(Resource):
producer = KafkaProducer(bootstrap_servers=current_app.config['kafka-broker-url'],
def __init__(self):
self.producer = KafkaProducer(bootstrap_servers=current_app.config['kafka-broker-url'],
value_serializer=lambda m: json.dumps(m, ensure_ascii=False)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment