search

nodefluent / kafka-streams

equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
https://nodefluent.github.io/kafka-streams/
MIT License
830 stars 111 forks source link

windowing function #170

Open Radu1990 opened 4 years ago

Radu1990 commented 4 years ago

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:

  1. When creating the window as in the example const {stream, abort} = consumeStream.window(from, to); are from and to absolute values ?
  2. How can I make a window continuous ? For example a 5 minutes window.