kafka_handler.setFormatter(kafka_formatter)
kafka_logger.addHandler(kafka_handler)
log = logging.getLogger(__name__)
kafka_handler.setFormatter(kafka_formatter)
kafka_logger.addHandler(kafka_handler)
log = logging.getLogger(__name__)
log.info("Syncing database...")
db_manager = DatabaseManager()
db_manager.create_tables()
log.info("Syncing database...")
db_manager = DatabaseManager()
db_manager.create_tables()