kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Adrian McCague (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result
Date Tue, 07 Feb 2017 11:21:41 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-4461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855792#comment-15855792
] 

Adrian McCague commented on KAFKA-4461:
---------------------------------------

[~guozhang] Thanks!

> When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not
produce any result
> ----------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-4461
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4461
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.1.0
>            Reporter: Hamidreza Afzali
>            Assignee: Adrian McCague
>              Labels: newbie, unit-test
>             Fix For: 0.10.3.0
>
>
> *Problem*
> When using ProcessorTopologyTestDriver in the latest Kafka 0.10.1, the combination of
map and .groupByKey does not produce any result. However, it works fine when using KStreamTestDriver.
> The topology looks like this:
> {code}
> builder.stream(Serdes.String, Serdes.Integer, inputTopic)
>  .map((k, v) => new KeyValue(fn(k), v))
>  .groupByKey(Serdes.String, Serdes.Integer)
>  .count(stateStore)
> {code}
> *Full examples*
> Examples for ProcessorTopologyTestDriver and KStreamTestDriver:
> https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13
> *Additional info*
> kafka-users mailing list:
> http://mail-archives.apache.org/mod_mbox/kafka-users/201611.mbox/%3CCAHwHRrVq1APVkNhP3HVqxujxRJEP9FwHV2NRcvPPsHX7Wujzng%40mail.gmail.com%3E



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message