mqtt message persistence
We want to make sure that workers that subscribe to topic data_parsed are receiving every message, even if they are temporarily disconnected from the broker (updates, bugs, network issues, ...).
- dispatcher services need to subscribe with
qos>0and need to have a uniqueclient_idfor this to work. - extractor/scheduler needs to send the message to topic
data_parsedwithqos>0
As all other MQTT Settings are passed as ENVVARs, MQTT_QOS will also be passed as ENVVAR from orchestration