Hi All, I'm working on a kafka streams application to basically aggreagte data over 5 min intervals.
The input topic is partitioned by id and then I want to use process function to aggregate data using state store and use punctuator to emit results. But I'm not sure how I can perform groupBy when using low level api's. My intention is to achieve the below topology. Topology: Source -> Map values -> GroupBy (internal key) -> Process -> Sink Need some help on how I can achieve this. Appreciate all the help. Thanks
