Event Streams Thoughts and Questions

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
1 Like

Second wildcards and UDTs and MQTT!