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 .
