X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osm_lcm%2Flcm.py;h=bf5f8599983ad40b48f6faa13babd4583f6e3c7d;hb=72a85a99a0f16ccc9c960565138c572660932a1d;hp=b306720246b9e4fa72c90ae522c8a0fb6a191f12;hpb=8eb2f28121480dd8402bf8c41a812973ab060fad;p=osm%2FLCM.git

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index b306720..bf5f859 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -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)
                 )