commit bfbc61cd0fd9dc2eca0edd8db0be828a0aac0417
author tierno <alfonso.tiernosepulveda@telefonica.com> Thu Jul 16 11:26:02 2020 +0000
committer tierno <alfonso.tiernosepulveda@telefonica.com> Thu Jul 16 17:24:12 2020 +0200
tree e533d043a0b8fd0658a4e8abb6f9f9293bc84506
parent 072b1ce375d593ad1372ea974319e11ea28153f6

fix 1131 Get non-procesed kafka messages at start

Change-Id: I4a775fc3bd0f1005af18f93d700386e1be168623
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>

osm_lcm/lcm.py

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index b914604..dd7c4ec 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -483,7 +483,7 @@
                 topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo", "pla")
                 topics_admin = ("admin", )
                 await asyncio.gather(
-                    self.msg.aioread(topics, self.loop, self.kafka_read_callback),
+                    self.msg.aioread(topics, self.loop, self.kafka_read_callback, from_beginning=True),
                     self.msg_admin.aioread(topics_admin, self.loop, self.kafka_read_callback, group_id=False)
                 )