"type": "record",
"name": "Message",
"namespace": "org.rflow",
"aliases": [],
"fields": [
    {"name": "data_type_name", "type": "string",
    "provenance",
     "type": {
         "type": "array",
         "items": {
             "type": "record",
             "name": "ProcessingEvent",
             "namespace": "org.rflow",
             "aliases": [],
             "fields": [
                 {"name": "component_instance_uuid", "type": "string",
                 "started_at", "type": ["string", "null"],
                 "completed_at", "type": ["string", "null"],
                 "context", "type": ["bytes", "null"]
             ]
         }
     }
    },
    {"name": "properties",
     "type": {
         "type": "map",
         "values": "string"
     }
    },
    {"name": "data_serialization_type",
     "type": {
         "type": "enum",
         "name": "DataSerializationType",
         "symbols": ["avro", "xml"]
     }
    },
    "data_schema", "type": "string",
    "data", "type": "bytes"
]

}