[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16928513#comment-16928513 ]
Gyula Fora commented on FLINK-14002: ------------------------------------ I am bit busy in the next few days but I can definitely fix this before the next release if no one picks it up earlier :) > 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)