Hi Kohki, Kafka streams windows use so called "segments" internally and their retention time cannot be lower than some minimum. Your configuration is set to less than this minimum, therefore is not accepted. Even Windows#until javadoc specifies it:
* Set the window maintain duration (retention time) in milliseconds. * This retention time is a guaranteed <i>lower bound</i> for how long a window will be maintained. For more info consider reading [this](https://github.com/confluentinc/examples/issues/76) issue. Regards, Jozef Sent from [ProtonMail](https://protonmail.ch), encrypted email based in Switzerland. -------- Original Message -------- Subject: Re: Immutable Record with Kafka Stream Local Time: February 24, 2017 7:11 PM UTC Time: February 24, 2017 7:11 PM From: tarop...@gmail.com To: users@kafka.apache.org 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
