Hello,

Say I have a stream, and want to determine whether or not a given "density"
of of records match a given condition.  For example, let's say I want to
how many of the last 10 records have a numerical value greater than 100.

Does the kafka streams DSL (or processor API) provide a way to do this type
of aggregation in a way that supports out of order messages?

I can't use a time window based aggregation here because my window is based
on a quantity of records (in this case, the last 10) rather than time.
However, I still want to know about the last 10 records regardless of what
order they arrive.

Thanks,
Ryan

Reply via email to