from osm_mon.core.config import Config
from osm_mon.dashboarder.dashboarder import Dashboarder
+import threading
def main():
log.info("Starting MON Dashboarder...")
log.debug("Config: %s", cfg.conf)
dashboarder = Dashboarder(cfg)
+ log.info("Starting MON kafka Consumer...")
+ threading.Thread(target=dashboarder.run, args=()).start()
+ log.info("Starting MON Dashboarder...")
dashboarder.dashboard_forever()