Daniel Heinrich created KAFKA-6936: -------------------------------------- Summary: Scala API Wrapper for Streams uses default serializer for table aggregate Key: KAFKA-6936 URL: https://issues.apache.org/jira/browse/KAFKA-6936 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 2.0.0 Reporter: Daniel Heinrich
On of the goals of the Scala API is to not fall back on the configured default serializer, but let the compiler provide them through implicits. The aggregate method on KGroupedStream misses to achieve this goal. Compared to the Java API is this behavior very supprising, because no other stream operation falls back to the default serializer and a developer assums, that the compiler checks for the correct serializer type. -- This message was sent by Atlassian JIRA (v7.6.3#76005)