Updated the OpenStack plugins
[osm/MON.git] / plugins / OpenStack / Aodh / notifier.py
index bd36f18..2068f03 100644 (file)
@@ -53,7 +53,7 @@ class Notifier(object):
         """Initialize alarm notifier."""
         self._response = OpenStack_Response()
 
-        self._producer = KafkaProducer("alarm_response", None)
+        self._producer = KafkaProducer("alarm_response")
 
     def notify(self, alarming):
         """Send alarm notifications responses to the SO."""