kafka-streams
kafka-streams copied to clipboard
windowing function
Hi there, I used the window.js example in order to create a kstream window
and I have a few questions regarding the way this is intended to work:
- When creating the window as in the example
const {stream, abort} = consumeStream.window(from, to);
arefrom
andto
absolute values ? - How can I make a window continuous ? For example a 5 minutes window.