Merging windowed KStreams with regular KStreams

[Sameer Kumar <sa...@gmail.com>]

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.

Re: Merging windowed KStreams with regular KStreams

["Matthias J. Sax" <ma...@confluent.io>]

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.
>