I have already written simple Kafka Streams jobs and now I have a slightly more complicated one. I have googled quite a bit but am not sure if I need a statestore or a materiallized view.
Most importantly, before I always created a new message again for each message. But now I want to create a new message based on many input messages.
I have several signals
S3, etc. these have three attributes each.
Each signal is a stream that has the value “false” for a time and then becomes “true” for a certain time. I want to determine the time the signal is true.
The new message should look like this.
S1 T1 false S1 T2 true S1 T3 true S1 T4 false S1 T5 false S1 T6 true S1 T7 true S1 T8 true S1 T9 false
S1 T2 T3 S1 T6 T8
I hope I could explain the use case.
Does anyone have an example or tips I can follow?