Hello Muhammad,
What you described here seems like an "append" aggregation, i.e. the
aggregated value is the concatenated list of records, and each aggregation
is to append the newly arrived record of the key to that concatenation
list. Right?
Guozhang
On Mon, Mar 2, 2020 at 6:51 AM Muhammad Su
Overload the functionality of Aggregate in KafkaStreams API such that ,
the lookup is allowed on a particular record of the value , in pair .
Also not only aggregate based on the last aggregate + present record , but
based on all the historical data , which means multiple values given a
single un
