Change-Id: I3b28547a1f3e21cb2ca39a3ca880d13fb82e0bb1
Signed-off-by: Atul Agarwal <atul.agarwal@altran.com>
while True:
try:
await self.msg_bus.aioread(topics, self._user_msg)
- log.info("Sucessfully subscribed to kafka topic(s) %s", str(topics))
break
except Exception as e:
# Failed to subscribe to kafka topics
while True:
try:
await self.msg_bus.aioread(topics, self._process_msg)
- log.info("Sucessfully subscribed to kafka topic(s) %s", str(topics))
break
except Exception as e:
# Failed to subscribe to kafka topic