Hi all, I'd like to start a discussion on KIP-1352, which proposes adding range aggregations to the Kafka Streams DSL. The current windowing API is limited to fixed time intervals and incremental aggregations. This KIP introduces a Range abstraction that allows users to define flexible record-centric ranges (by event time or event count) and perform non-incremental aggregations over them, emitting results as a KStream.
KIP page: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1352%3A+Ranges+and+Range+Aggregations+in+the+Kafka+Streams+DSL Looking forward to your feedback Hannes Buseyne
