You can use a custom window implementation to do this.
Cf https://github.com/confluentinc/kafka-streams-examples/blob/7.1.1-post/src/test/java/io/confluent/examples/streams/window/DailyTimeWindows.java
-Matthias On 1/18/23 6:33 AM, Amsterdam Luís de Lima Filho wrote:
Hello everyone, I need to perform windowed aggregation for weekly interval, from Monday to Monday, using Tumbling Windows. It does not seem to be supported: https://stackoverflow.com/questions/72785744/how-to-apply-an-offset-to-tumbling-window-in-order-to-delay-the-starting-of-win Can someone help me with a workaround or guidance on how to make a PR adding this feature? I need this to finish a migration from Flink to Kafka Streams in prod. Best, Amsterdam