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