Commit 3077865d authored by Matthias's avatar Matthias
Browse files

change topic names

parent baa10d65
Pipeline #24741 passed with stages
in 2 minutes and 37 seconds
......@@ -84,7 +84,7 @@ class FetchMappingFile(Resource):
raise ImportApiError(message)
# 2. write file content into kafka topic
topic = 'import-process-config'
topic = 'mb-di-config-prod'
try:
producer = KafkaProducer(bootstrap_servers=current_app.config['kafka-broker-url'],
key_serializer=str.encode)
......
Markdown is supported
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