Hi all, I have submitted KIP-261 to add a new API for window stores in order to optimize our current windowed aggregation implementations inside Streams DSL :
https://cwiki.apache.org/confluence/display/KAFKA/KIP-261%3A+Add+Single+Value+Fetch+in+Window+Stores This change would require people who have customized window store implementations to make code changes as part of their upgrade path. But I think it is worth while given that the fraction of customized window store should be very small. Feedback and suggestions are welcome. Thanks, -- Guozhang
