[ 
https://issues.apache.org/jira/browse/KAFKA-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314022#comment-17314022
 ] 

A. Sophie Blee-Goldman commented on KAFKA-9559:
-----------------------------------------------

Definitely +1 to refactoring, I found it pretty confusing to track down how 
this works at the moment. And yes, given how frequent of an issue the default 
serdes can be, we should absolutely throw an informative exception and not just 
an NPE -- whatever form that may take

> Change the default "default serde" from ByteArraySerde to null
> --------------------------------------------------------------
>
>                 Key: KAFKA-9559
>                 URL: https://issues.apache.org/jira/browse/KAFKA-9559
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: A. Sophie Blee-Goldman
>            Assignee: Leah Thomas
>            Priority: Blocker
>             Fix For: 3.0.0
>
>
> The current default "default serde" is not particularly useful, and in almost 
> all cases is intended to be overwritten either by setting the config 
> explicitly or by specifying serdes directly in the topology. If a user does 
> not set the config and misses specifying a serde they will get a runtime 
> ClassCastException once they start processing unless they are in fact 
> processing only bytes.
> We should change the default default to null, so that an exception will 
> instead be thrown immediately on startup if a user failed to specify a serde 
> somewhere in their topology and it falls back to the unset default.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to