Hello Boyang,
If I start the Kafka Stream process at the middle of a day, say, 10/24 16:00 pm, and with a tumbling window size of 1 day(24 hours). Would the next aggregation run at 10/25 00:00 AM? or at 10/25 16:00 PM? 在 2019-10-24 11:06:24，"Boyang Chen" <reluctanthero...@gmail.com> 写道： >Hey Zongzhen, > >I have implemented some similar functionality with KStream before. You >could just set tumbling window to 24 hours to get daily aggregation result. >As you just need calendar dates, the tumbling window computation starts >from system time 0 which is exactly cut-off daily. > >Boyang > >On Wed, Oct 23, 2019 at 7:21 PM 董宗桢 <jackdongd...@126.com> wrote: > >> Hello, >> >> >> I wanna run Kafka Streams on my system to aggregate the users' sales order >> transactions based on "daily". >> I know that Kafka Streams provides such mechanisms called tumbling window, >> but it seems to be just setting an interval to run the aggregation >> function. What I want is to aggregate by calendar date, which means, for >> example, from 10.23 00:00 AM to 10.24 00:00AM, kind of a scheduler which >> runs every day at 00:00AM to count all my transactions that happened last >> day. >> >> >> Is there any functionality in Kafka streams that I can use out of the box >> to implement my requirement? >> >> >> Thanks
