From 8ef6795a774a28b60e41272725ae7884ebae0dad Mon Sep 17 00:00:00 2001
From: aj7tesh <ajitesh1993@gmail.com>
Date: Wed, 30 Sep 2020 16:40:11 +0530
Subject: [PATCH] added kafka topics for WFM production env
---
config/kafka_topics.py | 5 +++++
server.py | 2 +-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/config/kafka_topics.py b/config/kafka_topics.py
index 0c28ebd2..d6bada0a 100644
--- a/config/kafka_topics.py
+++ b/config/kafka_topics.py
@@ -30,6 +30,11 @@ kafka_topic = [
"consumer":"anuvaad_nmt_translate",
"producer":"anuvaad_nmt_translate_processed",
"description":"kafka topics for WFM"
+ },
+ {
+ "consumer":"anuvaad_nmt_prod_translate",
+ "producer":"anuvaad_nmt_prod_translate_processed",
+ "description":"kafka topics for WFM Production"
}
]
diff --git a/server.py b/server.py
index 9cafbeeb..37b157d7 100755
--- a/server.py
+++ b/server.py
@@ -58,7 +58,7 @@ def start(config_file,
def kafka_function():
logger.info('starting kafka from nmt-server on thread-1')
- doc_translator(translation_server,[kafka_topic[0]['consumer'],kafka_topic[1]['consumer'],kafka_topic[2]['consumer'],kafka_topic[3]['consumer']])
+ doc_translator(translation_server,[kafka_topic[0]['consumer'],kafka_topic[1]['consumer'],kafka_topic[2]['consumer'],kafka_topic[3]['consumer'],kafka_topic[4]['consumer']])
if bootstrap_server_boolean:
t1 = threading.Thread(target=kafka_function)
--
GitLab