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

["Vikram Rawat (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-5689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15852709#comment-15852709 ] 

Vikram Rawat commented on FLINK-5689:
-------------------------------------

Since this has been fixed in v1.2 Snapshot documentation so closing the issue. 

> Kafka Connector Documentation gives Compile time errors (Java)
> --------------------------------------------------------------
>
>                 Key: FLINK-5689
>                 URL: https://issues.apache.org/jira/browse/FLINK-5689
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector
>    Affects Versions: 1.1.4
>         Environment: Java API for using Kafka Connector
>            Reporter: Vikram Rawat
>              Labels: kafka
>
> 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();



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)