[jira] (FLINK-5689) Kafka Connector Documentation gives Compile time errors (Java)

[Vikram Rawat (JIRA)]

Title: Message Title

Vikram Rawat created an issue   Flink / FLINK-5689 Kafka Connector Documentation gives Compile time errors (Java) Issue Type: Improvement Affects Versions: 1.1.4 Assignee: Unassigned Components: Kafka Connector Created: 31/Jan/17 06:31 Environment: Java API for using Kafka Connector Labels: kafka Priority: Major Reporter: Vikram Rawat https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/connectors/kafka.html Kafka Consumer Java section: Java code snippet given on the page, is as below: DataStream<String> stream = env .addSource(new FlinkKafkaConsumer08<>("topic", new SimpleStringSchema(), properties)) .print(); Should be changed to, i.e. DataStreamSink instead of DataStream: DataStreamSink<String> stream = env .addSource(new FlinkKafkaConsumer08<>("topic", new SimpleStringSchema(), properties)) .print(); Add Comment   This message was sent by Atlassian JIRA (v6.3.15#6346-sha1:dbc023d)