Damian, This type of questions seem to be common, could you add an entry into FAQ?
https://cwiki.apache.org/confluence/display/KAFKA/FAQ Guozhang On Tue, Jun 20, 2017 at 8:23 AM, Debasish Ghosh <ghosh.debas...@gmail.com> wrote: > On Tue, Jun 20, 2017 at 7:03 PM, Damian Guy <damian....@gmail.com> wrote: > > > m.groupBy(mapper, Serdes.String(), Serdes.String()).count(" > > HostAggregateCount") > > > > Thanks! It works .. > > > -- > Debasish Ghosh > http://manning.com/ghosh2 > http://manning.com/ghosh > > Twttr: @debasishg > Blog: http://debasishg.blogspot.com > Code: http://github.com/debasishg > -- -- Guozhang