fml2 created KAFKA-10722: ---------------------------- Summary: Timestamped store is used even if not desired Key: KAFKA-10722 URL: https://issues.apache.org/jira/browse/KAFKA-10722 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 2.6.0, 2.4.1 Reporter: fml2
I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I explicitly tell to materialize the result table using a usual (not timestamped) store. After that, the KTable is filtered and streamed. This stream is processed by a processor that accesses the store. The problem/bug ist that even if I tell to use a non-timestamped store, a timestamoed one is used, which leads to a ClassCastException. Here is a schema of the code: {code:java} KTable table = ...aggregate( initializer, // initializer for the KTable row aggregator, // aggregator Materialized.as(Stores.persistentKeyValueStore("MyStore")) // <-- Non-Timestamped! .withKeySerde(...).withValueSerde(...)); {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)