updated name of kafka topic

vvkmath · Aug 31, 2017 · f08bb2f · f08bb2f
1 parent 25ad575
commit f08bb2f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/predict/models/tensorflow/mnist/pipeline_predict.py b/predict/models/tensorflow/mnist/pipeline_predict.py
@@ -14,7 +14,7 @@
 _logger_stream_handler.setLevel(logging.INFO)
 _logger.addHandler(_logger_stream_handler)
 
-_logger_kafka_handler = KafkaHandler(hosts_list='localhost:9092', topic='prediction-inputs')
+_logger_kafka_handler = KafkaHandler(hosts_list='localhost:9092', topic='predictions')
 _logger.addHandler(_logger_kafka_handler)