Re: question: kafka stream Tumbling Window can't close when no producer sending message

2022-07-28 Thread John Roesler
Hello, Yes, this is correct. There is a difference between what we call “stream time” and regular “wall-clock time”. All the windowing operations need to be deterministic, otherwise your results would depend on when you run your program. For that reason, we have “stream time”, which takes its

question: kafka stream Tumbling Window can't close when no producer sending message

2022-07-28 Thread 张家帅
Dear kafka mangers: when I use kafka stream Tumbling Window, i found that if the producer send messages to source topic continuously, the stream TimeWindow could work as expected. but once i stop the producer, the last window couldn't close, until the producer send next message. Is this n