Guozhang, thanks for the reply, but I'm having trouble understanding, here's the statement from the document
Windowing operations are available in the Kafka Streams DSL > <http://docs.confluent.io/3.0.0/streams/developer-guide.html#streams-developer-guide-dsl>, > where users can specify a *retention period* for the window. This allows > Kafka Streams to retain old window buckets for a period of time in order to > wait for the late arrival of records whose timestamps fall within the > window interval. If a record arrives after the retention period has passed, > the record cannot be processed and is dropped. And I believe I can set retention period by using 'until' TimeWindows.of(60000).until(60000) After receiving a data from (00:06:00), I don't know why it still continue receiving data from time of 00:00:00, what is 'until' supposed to do ? Thanks -Kohki
