Change-Id: I4a775fc3bd0f1005af18f93d700386e1be168623
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>
topics = ("ns", "vim_account", "wim_account", "sdn", "nsi", "k8scluster", "k8srepo", "pla")
topics_admin = ("admin", )
await asyncio.gather(
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)
)
self.msg_admin.aioread(topics_admin, self.loop, self.kafka_read_callback, group_id=False)
)