diff options
Diffstat (limited to 'vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer')
| -rw-r--r-- | vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py b/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py index 1e311bf1..6d3fd612 100644 --- a/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py +++ b/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/consumer/CustomKafkaConsumer.py @@ -117,4 +117,4 @@ class CustomKafkaConsumer: # print("msg-value-type:: {}".format(type(msg.value().decode('utf-8')))) self.processMessage(msg.key(), msg.value()) - self.consumer.close()
\ No newline at end of file + self.consumer.close() |