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 Sufyian <s.m.sufy...@gmail.com> wrote: > Overload the functionality of Aggregate in KafkaStreams API such that , > the lookup is allowed on a particular record of the value , in <K,V> 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 unique key . > > For example : > ShopId+HotelId = key of the record > HotelName , hotelId = value of the record > > as a consumer of the event I should be able to lookup all the records given > a particular 'hotelId' also , aggregate based on the all the historical > data of this hotelId present in the state store . > -- -- Guozhang
