Systems and methods are disclosed for subscribing to messages generated from a plurality of edge devices. One method comprises receiving, at a cloud platform from a plurality of edge devices, a plurality of messages that comply with a common schema and receiving, at the cloud platform from a custom application, an annotation stream request to generate at least one annotation stream and an annotation filter request to generate one or more annotation filters. The at least one annotation stream and the one or more annotation filters are then generated by the cloud platform. Based on the one or more filters, one or more of the plurality of messages are published, by the cloud platform, to the at least one annotation stream.