I really like the idea of the event streams module. Just barely cobbled together a tag event stream from a UDT instance a log in a data base (much like a transaction group but cleaner IMO). I have so much more to learn with this new feature.
I wanted to see who else out there is playing with event streams. What are you building /thinking of building with it?
Next I’m gonna try out a “tags to Kafka” stream for certain UDTs as a way of logging domain events. I really like this compared to MQTT’s inability to retain historical messages.
Some improvement ideas I have:
- support for wild cards in tag paths list for tag events. It would be amazing to not have to statically configure the paths.
- ability to subscribe to at UDT type: imagine if I could create an event stream that was triggered any time a UDT instance of a certain type had a tag event. That would be huge
- Integration with MQTT Engine, ability to set subscriptions like a regular MQTT client and MQTT as a sync. Plus encoders SpB / protobuf
- Protobuf / avro encoding on Kafka messages
- Examples built into quick start showing event streams use cases