diff --git a/config/kafka_topics.py b/config/kafka_topics.py
index 0c28ebd261ec638bf897ce100490cc4bc79f5053..d6bada0abcaa54c55a4f774e4dbc3cb34c0311a5 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 9cafbeeb07b774af7e1572fb147073cc6e76dfa7..37b157d7cfa89e37d2dd2d28b3def6277be379fc 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)