Mqtt nachrichten haben kein AVRO schema und failen daher
MqttDatastreamAction hat kein AVRO-Schema, genauer SCHEMA_FILE = None.
wegen eines bugs failen die Nachrichten aktuell (siehe !42 (closed) ).
Der MR führ zu dem Folgeproblem das topic nun in act nicht verfügbar ist.
wir sollten topic auch nicht in user-generierte Nachrichten injizieren (as we do[1]), da wir evtuell daten überschreiben.
Daher brauchen wir einen neuen mechanismus das topic an act zu übergeben, zb indem wir act anders definieren def act(message, topic)