X-Git-Url: https://gerrit.onap.org/r/gitweb?p=demo.git;a=blobdiff_plain;f=vnfs%2FDAaaS%2Fmicroservices%2FPythonApps%2Fpython-kafkaConsumer-inference-app%2Fsrc%2Fconsumer%2FCustomKafkaConsumer.py;h=6d3fd612d621d85f4a8947a5a00af8fc736ec8a2;hp=1e311bf18309a73c86d058c59f682563802176e9;hb=00107ed0ee9911ac761a544bada794a1ebb26ddf;hpb=89da408dd79bcc7cfb4d89033da435c974c13e70 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()