|
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.
|