FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs

Elias Levy
Looks like the Flink Kafka connector page, in the Producer section, is missing a section for the new FlinkKafkaProducer011 producer.  Given that the new producer no longer has a static writeToKafkaWithTimestamps method, it would be good to add a section that specifies that you must now use DataStream.addSink.
Reply | Threaded
Open this post in threaded view
|

Re: FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs

Fabian Hueske-2
Hi Elias,

thanks for reporting this issue.
I created FLINK-8260 [1] to extend the documentation.

Best, Fabian

[1] https://issues.apache.org/jira/browse/FLINK-8260

2017-12-14 1:07 GMT+01:00 Elias Levy <[hidden email]>:
Looks like the Flink Kafka connector page, in the Producer section, is missing a section for the new FlinkKafkaProducer011 producer.  Given that the new producer no longer has a static writeToKafkaWithTimestamps method, it would be good to add a section that specifies that you must now use DataStream.addSink.