- msg_bus = MessageBusClient(config)
- topics = ["alarm_request", "users", "project"]
- for topic in topics:
- msg_bus.aiowrite(topic, 'echo', 'dummy message')
+ producer = kafka.KafkaProducer(
+ bootstrap_servers=[
+ config.conf.get("message", {}).get("host", "kafka")
+ + ":"
+ + config.conf["message"].get("port")
+ ]
+ )
+ mon_topics = ["alarm_request", "users", "project"]
+ for mon_topic in mon_topics:
+ producer.send(mon_topic, key=b"echo", value=b"dummy message")