You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Elias Levy <fe...@gmail.com> on 2017/12/14 00:07:26 UTC

FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs

Looks like the Flink Kafka connector page, in the Producer section
<https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/kafka.html#kafka-producer>,
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.

Re: FlinkKafkaProducer011 and Flink 1.4.0 Kafka docs

Posted by Fabian Hueske <fh...@gmail.com>.

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 <fe...@gmail.com>:

> Looks like the Flink Kafka connector page, in the Producer section
> <https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/connectors/kafka.html#kafka-producer>,
> 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.
>