SEBA-207 Generate switch port alarms;
Add kind field to switch port;
Add managementAddress and pull step
Change-Id: I17ec83d3ae9e82c8c3f99151115a35e299ee0d60
diff --git a/xos/synchronizer/fabric-synchronizer.py b/xos/synchronizer/fabric-synchronizer.py
index 1c98ecd..c4ce3a3 100755
--- a/xos/synchronizer/fabric-synchronizer.py
+++ b/xos/synchronizer/fabric-synchronizer.py
@@ -19,6 +19,7 @@
import os
from xossynchronizer import Synchronizer
from xosconfig import Config
+from xoskafka import XOSKafkaProducer
base_config_file = os.path.abspath(os.path.dirname(os.path.realpath(__file__)) + '/config.yaml')
mounted_config_file = os.path.abspath(os.path.dirname(os.path.realpath(__file__)) + '/mounted_config.yaml')
@@ -28,4 +29,7 @@
else:
Config.init(base_config_file, 'synchronizer-config-schema.yaml')
+# init kafka producer connection
+XOSKafkaProducer.init()
+
Synchronizer().run()