From 1e4456c4faef7fd3b21024c837e17c717a5d7bfc Mon Sep 17 00:00:00 2001 From: tierno Date: Thu, 16 Jul 2020 11:26:02 +0000 Subject: [PATCH] fix 1131 Get non-procesed kafka messages at start Change-Id: I4a775fc3bd0f1005af18f93d700386e1be168623 Signed-off-by: tierno --- osm_lcm/lcm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) ) -- 2.25.1