We always use: <origin_id> <timestamp> <event_type> {payload_json} \n This way you know what json parser to use for which line. origin_id and timestamp is ju

We always use: <origin_id> <timestamp> <event_type> {payload_json} \n This way you know what json parser to use for which line. origin_id and timestamp is just something we always use with our EventStream In the database it also has one iterator per origin_id, and within an origin one iterator per event_type. This way you can listen to both an origin_id and a specific event_type while making sure you can batch fetch any missing data if the iterators skip a beat.