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%2Fproducer%2FCustomKafkaProducer.py;h=43303761ba2412d265527cdd87fe82df94523db2;hp=8f726bd987bf82c447da730ed4045d30285e555f;hb=00107ed0ee9911ac761a544bada794a1ebb26ddf;hpb=89da408dd79bcc7cfb4d89033da435c974c13e70 diff --git a/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/CustomKafkaProducer.py b/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/CustomKafkaProducer.py index 8f726bd9..43303761 100644 --- a/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/CustomKafkaProducer.py +++ b/vnfs/DAaaS/microservices/PythonApps/python-kafkaConsumer-inference-app/src/producer/CustomKafkaProducer.py @@ -35,4 +35,4 @@ class CustomKafkaProducer: logging.error('%s raised an error', err) else: logging.info("Message delivered to %s on partition %s", - msg.topic(), msg.partition()) \ No newline at end of file + msg.topic(), msg.partition())