You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/09/28 18:15:00 UTC

[jira] [Created] (KAFKA-7456) Serde Inheritance in Streams DSL

Guozhang Wang created KAFKA-7456:
------------------------------------

             Summary: Serde Inheritance in Streams DSL
                 Key: KAFKA-7456
                 URL: https://issues.apache.org/jira/browse/KAFKA-7456
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: Guozhang Wang
            Assignee: Guozhang Wang
             Fix For: 2.1.0


This is a prerequisite for further topology optimization in the Streams DSL: we should let different operators inside the DSL to be able to pass along key and value serdes if they are not explicitly specified by users. The serde specification precedence should generally be:

1) Overridden values via control objects (e.g. Materialized, Serialized, Consumed, etc)
2) Serdes that can be inferred from the operator itself (e.g. groupBy().count(), where value serde can default to `LongSerde`).
3) Serde inherited from parent operator if possible (note if the key / value types have been changed, then the corresponding serde cannot be inherited).
4) Default serde specified in the config.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)