def METHOD_NAME(self, topic_id):
    log.info(f"Init topic: {topic_id}")
    event_client = EventClient(topic_id)
    event_client.async_consume(app=None, handler=self.handler, group_id="ch-notifications")
    self._event_clients.append(event_client)