Description
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:
builder.stream(Serdes.String, Serdes.Integer, inputTopic) .map((k, v) => new KeyValue(fn(k), v)) .groupByKey(Serdes.String, Serdes.Integer) .count(stateStore)
Full examples
Examples for ProcessorTopologyTestDriver and KStreamTestDriver:
https://gist.github.com/hrafzali/c2f50e7b957030dab13693eec1e49c13
Additional info
kafka-users mailing list:
Attachments
Issue Links
- links to