[ https://issues.apache.org/jira/browse/KAFKA-10408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180882#comment-17180882 ]
Matthias J. Sax commented on KAFKA-10408: ----------------------------------------- Another example implementation is this one: [https://github.com/confluentinc/kafka-streams-examples/blob/5.5.0-post/src/test/java/io/confluent/examples/streams/window/DailyTimeWindows.java] > Calendar based windows > ---------------------- > > Key: KAFKA-10408 > URL: https://issues.apache.org/jira/browse/KAFKA-10408 > Project: Kafka > Issue Type: New Feature > Components: streams > Affects Versions: 2.6.0 > Reporter: Antony Stubbs > Priority: Minor > Labels: needs-kip > > A date based window, for example aggregate all payments made until each month > date of the 15th, or all payments made each year until April 1st. > Should handle time zones "properly", e.g. allow user to specify which time > zone to base it on. > Also should support setting a time cut off, and just simply "midnight" in the > given zone. (.e.g 6pm April 15th). > Ideally will also support day offsets, e.g. last day of every month, first > Tuesday of each week, last Friday of the month. > Example implementation of a specific aggregator, with a window implementation > implicitly embedded: > [https://github.com/astubbs/ks-tributary/blob/denormalisation-base-cp-libs/streams-module/src/main/java/io/confluent/ps/streams/processors/YearlyAggregator.java] > -- This message was sent by Atlassian Jira (v8.3.4#803005)