fix 1131 Get non-procesed kafka messages at start 56/9456/1 v7.1.5
authortierno <alfonso.tiernosepulveda@telefonica.com>
Thu, 16 Jul 2020 11:26:02 +0000 (11:26 +0000)
committertierno <alfonso.tiernosepulveda@telefonica.com>
Fri, 17 Jul 2020 14:48:46 +0000 (14:48 +0000)
Change-Id: I4a775fc3bd0f1005af18f93d700386e1be168623
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>
osm_lcm/lcm.py

index b306720..bf5f859 100644 (file)
@@ -470,7 +470,7 @@ class Lcm:
                 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)
                 )