import json
import sys
import requests
-sys.path.append("../../../core/message_bus")
-from producer import KafkaProducer
+sys.path.append(os.path.join(os.path.dirname(os.path.abspath(__file__)), '..', '..', '..','..'))
+from osm_mon.core.message_bus.producer import KafkaProducer
#from core.message_bus.producer import KafkaProducer
try:
logger.info("Alarm details: {}".format(alarm_data))
#Publish Alarm details
- kafkaMsgProducer = KafkaProducer()
+ kafkaMsgProducer = KafkaProducer("alarm_response")
kafkaMsgProducer.publish(topic='alarm_response', key='notify_alarm', value=alarm_data)
#return 201 on Success