I guess it depend what you want as an output... But what you suggest would work. You can also apply a .map() to the windowed stream and extract the actual record key from the window (ie, strip away the window)
-Matthias On 7/26/17 6:15 PM, Sameer Kumar wrote: > I wanted to merge two KStreams one of them is a windowed stream and another > one is of type <String, Integer>, what is the preferred way of merging them. > > One way I thought was to run a map phase and create a windowed instance > based on system.currentmillis. > > -Sameer. >
signature.asc
Description: OpenPGP digital signature
