Hello all, I would like to kick off discussion of this KIP aimed at providing sliding window semantics to DSL aggregations.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-450%3A+Sliding+Window+Aggregations+in+the+DSL Please take a look and share any thoughts you have regarding the API, semantics, design, etc! I also have a POC PR open with the "naive" implementation for your reference: https://github.com/apache/kafka/pull/6549 Cheers, Sophie
