Hi, I have created a proposal for adding some additional aggregation APIs like count.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-747+Add+support+for+basic+aggregation+APIs I have noted down some of the issues that need discussion. Thanks to Matthias for helping me with the scope of the proposal. Thanks Mohan
