[jira] [Created] (KAFKA-4461) When using ProcessorTopologyTestDriver, the combination of map and .groupByKey does not produce any result

["Hamidreza Afzali (JIRA)" <ji...@apache.org>]

Hamidreza Afzali created KAFKA-4461:
---------------------------------------

             Summary: 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
            Priority: Blocker


*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 example*
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.4#6332)