# Event Streams Thoughts and Questions

**URL:** <https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286>\
**Category:** Ignition 8.3 Early Access\
**Tags:** ignition83\
**Created:** [August 2, 2025, 3:19pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286 "2025-08-02T15:19:12Z")\
**Posts on this page:** 13\
**Page:** 1

<div class="post-metadata">

**Author:** ![jomaldonado209](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/jomaldonado209/32/78371_2.png) [@jomaldonado209](https://forum.inductiveautomation.com/u/jomaldonado209)\
**Post date:** [August 2, 2025, 3:19pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/1 "2025-08-02T15:19:12Z")

</div>

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

---

<div class="post-metadata">

**Author:** ![Jon\_Forbord](https://avatars.discourse-cdn.com/v4/letter/j/d9b06d/32.png) [@Jon\_Forbord](https://forum.inductiveautomation.com/u/Jon_Forbord)\
**Post date:** [August 2, 2025, 7:04pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/2 "2025-08-02T19:04:40Z")

</div>

Second wildcards and UDTs and MQTT!

---

<div class="post-metadata">

**Author:** ![Cade\_Allen](https://avatars.discourse-cdn.com/v4/letter/c/db5fbb/32.png) [@Cade\_Allen](https://forum.inductiveautomation.com/u/Cade_Allen)\
**Post date:** [August 4, 2025, 1:48pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/3 "2025-08-04T13:48:00Z")

</div>

I agree with the tag path wildcards - especially if they could be used in the middle of paths. For example, if I had a Motors folder spread across multiple production line folders.

UDT integration with event streams would be massive. That's something that isn't possible with transaction groups, and having this feature would be incredible.

---

<div class="post-metadata">

**Author:** ![VinceV](https://avatars.discourse-cdn.com/v4/letter/v/bb73d2/32.png) [@VinceV](https://forum.inductiveautomation.com/u/VinceV)\
**Post date:** [August 4, 2025, 2:03pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/4 "2025-08-04T14:03:11Z")

</div>

I haven't had the chance to play it with yet (waiting on our system egineer to set up the beta) but I'm hoping to integrate it with RabbitMQ at some point in the future. Over the last couple of years we've hacked together a system that's based on the RabbitMQ Java client library, which works for our purposes, but it'd be nice if it could be properly integrated with these event streams.

---

<div class="post-metadata">

**Author:** ![Steve\_Laubach](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/steve_laubach/32/60900_2.png) [@Steve\_Laubach](https://forum.inductiveautomation.com/u/Steve_Laubach)\
**Post date:** [August 4, 2025, 2:20pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/5 "2025-08-04T14:20:13Z")

</div>

I've only scratched the surface on Event Streams so far but I am definitely going to be listening closely at ICC this year as they talk about them. I think you've nailed some of the use cases for them and I feel like they are designed to be flexible to build whatever you have in mind.

---

<div class="post-metadata">

**Author:** ![jomaldonado209](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/jomaldonado209/32/78371_2.png) [@jomaldonado209](https://forum.inductiveautomation.com/u/jomaldonado209)\
**Post date:** [August 4, 2025, 10:48pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/6 "2025-08-04T22:48:07Z")

</div>

I did find an answer to my MQTT question in another thread

So I hope we'll see it one day. Hopefully Cirrus Link is on it.

I guess that's what happens when MQTT is implemented by a partner and not first party.

Still excited to see it none the less.

> [@\[Question\] V8.3 - Streams and Available Connectors](https://forum.inductiveautomation.com/t/question-v8-3-streams-and-available-connectors/101084/4):
>
> Even though I argued we should do MQTT sources and handlers in house I guess it was decided to leave it up to Cirrus Link. I assume it’s happening, not sure on the timeline. In the meantime, yes, you could just use a tag source if it’s already being brought into Ignition.

---

<div class="post-metadata">

**Author:** ![jomaldonado209](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/jomaldonado209/32/78371_2.png) [@jomaldonado209](https://forum.inductiveautomation.com/u/jomaldonado209)\
**Post date:** [August 4, 2025, 10:50pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/7 "2025-08-04T22:50:13Z")

</div>

That thread I linked in my last comment, Kevin Herron mentioned that the Streams Module is extensible via the SDK.

Not sure if you wrote your own module for RabbitMQ but sounds like it'd be the same route to add it to Event Streams.

---

<div class="post-metadata">

**Author:** ![jomaldonado209](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/jomaldonado209/32/78371_2.png) [@jomaldonado209](https://forum.inductiveautomation.com/u/jomaldonado209)\
**Post date:** [August 5, 2025, 8:53pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/8 "2025-08-05T20:53:10Z")

</div>

Cirrus Link just announced Event Streams support in their updated modules

---

<div class="post-metadata">

**Author:** ![Andre\_Hennecke](https://avatars.discourse-cdn.com/v4/letter/a/e95f7d/32.png) [@Andre\_Hennecke](https://forum.inductiveautomation.com/u/Andre_Hennecke)\
**Post date:** [August 12, 2025, 1:38pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/9 "2025-08-12T13:38:55Z")

</div>

Reusing the thread for Even Streams Questions:

1. There is the following known ‘issue’ with Event Streams, that Records can be lost from a _buffer_ when an _event stream_ is saved or disabled​. Is this something which should eventually be fixed, so that the data in a buffer is not lost or does this work as intentended.
2. Is there some documentation available for redundant gateways and event streams? Is this supported an if, does is also copy the buffer to the redundant gateway?

###

---

<div class="post-metadata">

**Author:** ![Andre\_Hennecke](https://avatars.discourse-cdn.com/v4/letter/a/e95f7d/32.png) [@Andre\_Hennecke](https://forum.inductiveautomation.com/u/Andre_Hennecke)\
**Post date:** [August 13, 2025, 1:49pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/10 "2025-08-13T13:49:05Z")

</div>

Maybe I missed something, but how is Event Streams useful for the Source “Tag Event” 🙃 :

The documention [Source Data and Metadata | Ignition User Manual](https://www.docs.inductiveautomation.com/docs/8.3/ignition-modules/event-streams/types-of-sources/source-data-and-metadata#tag-event) says that there is no extractable data for the Source “Tag Event”, but Metadata, which is provided by the user.

1. Does this mean, that there is no way to get the value for a Tag Event Source?
2. How can the user define Metadata for a Tag Event?

> **Tag Event**
> 
> ### **Event Object - Data**
> 
> There is no extractable Tag Event event object data.
> 
> ### **Event Object - Metadata**
> 
> There is no pre-existing extractable Tag Event event object data, as this is provided by the user.

---

<div class="post-metadata">

**Author:** ![Kevin.Herron](https://sea1.discourse-cdn.com/inductiveautomation/user_avatar/forum.inductiveautomation.com/kevin.herron/32/7259_2.png) [@Kevin.Herron](https://forum.inductiveautomation.com/u/Kevin.Herron)\
**Post date:** [August 13, 2025, 2:29pm UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/11 "2025-08-13T14:29:03Z")

</div>

I think the docs are wrong. The event data should be the tag value, and the metadata should have two properties: `tagPath` and `isInitial`.

---

<div class="post-metadata">

**Author:** ![Andre\_Hennecke](https://avatars.discourse-cdn.com/v4/letter/a/e95f7d/32.png) [@Andre\_Hennecke](https://forum.inductiveautomation.com/u/Andre_Hennecke)\
**Post date:** [August 14, 2025, 8:05am UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/12 "2025-08-14T08:05:41Z")

</div>

That work. Thank you!

- **event.data** returns a json with value, quality and timestamp
- **event.metadata** returns a json with tagPath and isInitial

---

<div class="post-metadata">

**Author:** ![hsr](https://avatars.discourse-cdn.com/v4/letter/h/d2c977/32.png) [@hsr](https://forum.inductiveautomation.com/u/hsr)\
**Post date:** [August 20, 2025, 11:15am UTC](https://forum.inductiveautomation.com/t/event-streams-thoughts-and-questions/109286/13 "2025-08-20T11:15:50Z")

</div>

I've been testing the Event Streams with the MQTT source (8.3 beta 4). I cant find any way to store the topic in the database? Payload is in the {**[event.data](http://event.data/)**}, but is the topic avaliable? It seems the {event.metadata} is empty. The topic needs to be included in the event object!

It would also be nice to create column type JSON when using Postgres database (to store the raw payload)
