Damian, Hamid: I looked at the source code and suspect that it is because of the auto-repartitioning which causes the topology to not directly forward the record to the child processors but send to an intermediate topic. In our tests we only do "groupByKey" without map, and hence auto-repartitioning will not be introduced.
What bothers me is that, for KStreamTestDriver it should have the similar issue as well (it does not handle intermediate topic either), but Hamid reports it actually works fine. Anyways, I think there is an issue with at least ProcessorTopologyTestDriver, and very likely with KStreamTestDriver as well, and we should file a JIRA and continue investigating and fixing it. Guozhang On Thu, Nov 24, 2016 at 7:34 AM, Hamidreza Afzali < hamidreza.afz...@hivestreaming.com> wrote: > Hi Damian, > > It processes correctly when using KStreamTestDriver. > > Best, > Hamid > > -- -- Guozhang
