- # await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop)
- await self.msg.aiowrite(
- "vim_account", "echo", "dummy message", loop=self.loop
- )
+ for kafka_topic in self.kafka_topics:
+ await self.msg.aiowrite(kafka_topic, "echo", "dummy message")