[
https://issues.apache.org/jira/browse/FLINK-18780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17183002#comment-17183002
]
Qingsheng Ren commented on FLINK-18780:
---------------------------------------
Thanks [~becket_qin] ~ I'll create another ticket about using builder style
for Kafka consumer and producer.
Also the documentation of Kafka DataStream producer needs to be updated too.
Currently the example is using this non-existent constructor, which is
misleading.
> FlinkKafkaProducer should add another constructor accepting
> SerializationSchema
> -------------------------------------------------------------------------------
>
> Key: FLINK-18780
> URL: https://issues.apache.org/jira/browse/FLINK-18780
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Kafka
> Affects Versions: 1.11.0, 1.11.1
> Reporter: Qingsheng Ren
> Priority: Major
>
> Currently `FlinkKafkaProducer` doesn't have a constructor like
> `FlinkKafkaProducer(String, SerializationSchema<IN>, Properties, Semantic)`
> This is used as an example in Kafka DataStream Connector's documentation.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
