[jira] [Created] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

Shang Yuanchun (Jira)
Gyula Fora created FLINK-14002:
----------------------------------

             Summary: 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


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)