Fix input/output reference naming bug

microsoft · Feb 6, 2019 · c74f28e · c74f28e
1 parent 95dd525
commit c74f28e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/agogosml_cli/cli/templates/{{cookiecutter.PROJECT_NAME_SLUG}}/output_writer/main.py b/agogosml_cli/cli/templates/{{cookiecutter.PROJECT_NAME_SLUG}}/output_writer/main.py
@@ -8,8 +8,8 @@
 
 if __name__ == '__main__':
     config = dict(os.environ)
-    if 'KAFKA_TOPIC_INPUT' in config:
-        config['KAFKA_TOPIC'] = config.pop('KAFKA_TOPIC_INPUT')
+    if 'KAFKA_TOPIC_OUTPUT' in config:
+        config['KAFKA_TOPIC'] = config.pop('KAFKA_TOPIC_OUTPUT')
 
     CFG = {
         'client': {