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

Aljoscha Krettek commented on FLINK-14002:
------------------------------------------

I agree, that the current design is not optimal. One reason is that we tried to 
bridge the divide between the previous interface and this new one, 
functionality wise.

We can always reconsider and un-deprecate the previous interfaces if we agree 
that that is better going forward.

> FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt 
> take default topic
> ----------------------------------------------------------------------------------------------
>
>                 Key: FLINK-14002
>                 URL: https://issues.apache.org/jira/browse/FLINK-14002
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Kafka
>            Reporter: Gyula Fora
>            Priority: Major
>
> When the KafkaSerializationSchema is used the user has the to provide the 
> topic always when they create the ProducerRecord.
> The defaultTopic specified in the constructor (and enforced not to be null) 
> will always be ignored, this is very misleading.
> We should depracate these constructors and create new ones without 
> defaultTopic.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)

Reply via email to