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)