Major Description
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.
Attachments
Issue Links
- links to