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)

Reply via email to