self.logger.error("Task Kafka Exception {}".format(e))
await asyncio.sleep(1, loop=self.loop)
self.logger.debug("Task Kafka terminating")
self.logger.error("Task Kafka Exception {}".format(e))
await asyncio.sleep(1, loop=self.loop)
self.logger.debug("Task Kafka terminating")