From 865c35c7cdc508749bf51ebd2594996d14afd8c1 Mon Sep 17 00:00:00 2001 From: palsus Date: Fri, 16 Apr 2021 07:36:15 +0000 Subject: [PATCH] Fix for 1433 Add dummy write to kafka Change-Id: I4c102e52612a50a8fe3d562c6435d95426a56b4f Signed-off-by: palsus --- osm_mon/cmd/mon_utils.py | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/osm_mon/cmd/mon_utils.py b/osm_mon/cmd/mon_utils.py index 6d383d0..9640543 100644 --- a/osm_mon/cmd/mon_utils.py +++ b/osm_mon/cmd/mon_utils.py @@ -19,7 +19,7 @@ import time import socket import logging import kafka -from osm_mon.core.message_bus_client import MessageBusClient + def wait_till_commondb_is_ready(config, process_name="osm-mon", commondb_wait_time=5): @@ -59,14 +59,16 @@ def wait_till_kafka_is_ready(config, process_name="osm-mon", kafka_wait_time=5): bootstrap_servers=[config.conf.get("message", {}).get("host", "kafka") + ":" + config.conf["message"] .get("port")]) - topics = consumer.topics() - logging.debug("Number of topics found: %s", len(topics)) + all_topics = consumer.topics() + logging.debug("Number of topics found: %s", len(all_topics)) # Send dummy message in kafka topics. If kafka is not ready exception will be thrown. - 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") # Kafka is ready now kafka_ready = True -- 2.17.1