# Initialize Kafka consumer
log.info("Connecting to Kafka server at %s", kafka_server)
# Initialize Kafka consumer
log.info("Connecting to Kafka server at %s", kafka_server)
consumer = KafkaConsumer(bootstrap_servers=kafka_server,
key_deserializer=bytes.decode,
consumer = KafkaConsumer(bootstrap_servers=kafka_server,
key_deserializer=bytes.decode,
log.info("Sending scaling action message for ns: %s", alarm_id)
lcm_client.scale(alarm.scaling_record.nsr_id, alarm.scaling_record.name, alarm.action)
except ScalingAlarm.DoesNotExist:
log.info("Sending scaling action message for ns: %s", alarm_id)
lcm_client.scale(alarm.scaling_record.nsr_id, alarm.scaling_record.name, alarm.action)
except ScalingAlarm.DoesNotExist: