How to do a wall-clock time aggregation

[pitermarx]

I've just realized that when doing an aggregation on a temporal window, what I get is an ever-updating IKTable of the values, and the windows are done via the stream time, and not wall-clock time.

My idea was to "group" all the events that happen on each minute and emit a stream of events that would have the aggregation of it, that only had a rate of 1 event per minute. (this might be complicated by multiple consumer groups, but let's imagine for now a single consumer on a single partition)

I'm seeing some options like supress and punctuate in the Java implementation but I'm not seeing a way out in the dotnet implementation.

2 questions
1 - Is there any way to do what I want in Streamiz?
2 - Does it even make sense to think in terms of wall-clock time when using KStreams? do people usually do it?

[LGouellec]

Hi @pitermarx ,

Unfortunately the wall-clock aggregation is not available yet.

1 - Is there any way to do what I want in Streamiz?
Not possible for the moment

2 - Does it even make sense to think in terms of wall-clock time when using KStreams? do people usually do it?
Yes of course, the feature is coming soon for 1.5.0

[LGouellec]

Hi @pitermarx ,

Unfortunately the wall-clock aggregation is not available yet.

1 - Is there any way to do what I want in Streamiz?
Not possible for the moment

2 - Does it even make sense to think in terms of wall-clock time when using KStreams? do people usually do it?
Yes of course, the feature is coming soon for 1.5.0

[pitermarx]

This is Gr8 news. Do you have a ballpark idea of when 1.5 will be published?

[LGouellec]

End Q2' 2023