In Kafka 0.10.1 a deduplication cache was introduced for aggregates, that reduces the downstream load for a KTable changelog stream.
If you want to disable the cache for testing, you can set StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG to zero. Compare: http://docs.confluent.io/current/streams/developer-guide.html#memory-management -Matthias On 11/22/16 12:37 PM, Hamidreza Afzali wrote: > Hi, > > When using ProcessorTopologyTestDriver in the latest Kafka 0.10.1, the > combination of .map(...) and .groupByKey(...).count(...) does not produce any > result. > > 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) > > It works if we remove .map(...) or .groupByKey(...).count(...). > > Is this a bug? > > Thanks in advance, > Hamid >
signature.asc
Description: OpenPGP digital signature
