Updated kafka version

[osm/MON.git] / osm_mon / core / message_bus / common_consumer

diff --git a/osm_mon/core/message_bus/common_consumer b/osm_mon/core/message_bus/common_consumer
index e981184..bb8ce0c 100755 (executable)
--- a/osm_mon/core/message_bus/common_consumer
+++ b/osm_mon/core/message_bus/common_consumer
@@ -24,7 +24,7 @@ import logging
 import sys
 import os
 
-sys.path.insert(0, os.path.abspath('../'))
+sys.path.append("/root/MON")
 
 logging.basicConfig(filename='MON_plugins.log',
                     format='%(asctime)s %(message)s',