Fix Bug 914: Updating VNFD the first time shows ProducerClosed error

Change-Id: I02f9ad72bbc4256954030b4d338af242d1f81b81
Signed-off-by: delacruzramo <pedro.delacruzramos@altran.com>

diff --git a/debian/python3-osm-common.postinst b/debian/python3-osm-common.postinst
index 2c60d98..9d91a84 100755 (executable)
--- a/debian/python3-osm-common.postinst
+++ b/debian/python3-osm-common.postinst
@@ -20,8 +20,8 @@
 echo "POST INSTALL OSM-COMMON"
 echo "Installing python dependencies via pip..."
 
-pip3 install --upgrade aiokafka==0.4.*
-pip3 install --upgrade pymongo==3.7.*
+pip3 install --upgrade aiokafka
+pip3 install --upgrade pymongo
 pip3 install --upgrade pyyaml==5.*
 pip3 install pycrypto   # added dependency python3-crypto seems not working
 

diff --git a/osm_common/msgkafka.py b/osm_common/msgkafka.py
index 1e22c9f..91775f2 100644 (file)
--- a/osm_common/msgkafka.py
+++ b/osm_common/msgkafka.py
@@ -64,11 +64,15 @@ class MsgKafka(MsgBase):
         :param msg: message content, can be string or dictionary
         :return: None or raises MsgException on failing
         """
-        try:
-            self.loop.run_until_complete(self.aiowrite(topic=topic, key=key, msg=msg))
-
-        except Exception as e:
-            raise MsgException("Error writing {} topic: {}".format(topic, str(e)))
+        retry = 2   # Try two times
+        while retry:
+            try:
+                self.loop.run_until_complete(self.aiowrite(topic=topic, key=key, msg=msg))
+                break
+            except Exception as e:
+                retry -= 1
+                if retry == 0:
+                    raise MsgException("Error writing {} topic: {}".format(topic, str(e)))
 
     def read(self, topic):
         """