mdx.mtmc.stream.config_manager module

class ConfigManager(config: AppConfig, kafka_message_broker: KafkaMessageBroker)

Bases: object

Module to manage configuration

Parameters:

• config (AppConfig) – configuration for the app

• kafka_message_broker (KafkaMessageBroker) – Kafka message broker

config_manager = ConfigManager(config, kafka_message_broker)

process_notifications_and_update_config(config_notifications: List[Notification], producer: kafka.KafkaProducer)

Processes notifications and updates configuration

Parameters:

• config_notifications (List[Notification]) – notifications of configuration

• producer (KafkaProducer) – Kafka producer

Returns:

None

config_manager.process_notifications_and_update_config(config_notifications, producer)