[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925398#comment-16925398 ]
Gyula Fora commented on FLINK-14002: ------------------------------------ Actually the default topic is used in case of KafkaContextAware serialization schemas which might cause further problems. > 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)