You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Hamidreza Afzali <ha...@hivestreaming.com> on 2016/12/01 13:17:30 UTC
Re: kafka 0.10.1 ProcessorTopologyTestDriver issue with .map and
.groupByKey.count
I have added an example for KStreamDriver to the GitHub Gist and updated the JIRA issue.
https://issues.apache.org/jira/browse/KAFKA-4461
https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13
Hamid
Re: kafka 0.10.1 ProcessorTopologyTestDriver issue with .map and .groupByKey.count
Posted by Guozhang Wang <wa...@gmail.com>.
Thanks!
On Thu, Dec 1, 2016 at 5:17 AM, Hamidreza Afzali <
hamidreza.afzali@hivestreaming.com> wrote:
> I have added an example for KStreamDriver to the GitHub Gist and updated
> the JIRA issue.
>
> https://issues.apache.org/jira/browse/KAFKA-4461
>
> https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13
>
>
> Hamid
>
>
--
-- Guozhang