tillrohrmann commented on a change in pull request #10762: [FLINK-15115][kafka]
Drop Kafka 0.8/0.9
URL: https://github.com/apache/flink/pull/10762#discussion_r365321100
##########
File path: docs/dev/connectors/kafka.zh.md
##########
@@ -161,22 +151,18 @@ Flink 的 Kafka consumer 称为 `FlinkKafkaConsumer08`（或适用于
Kafka 0.9.
{% highlight java %}
Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "localhost:9092");
-// 仅 Kafka 0.8 需要
-properties.setProperty("zookeeper.connect", "localhost:2181");
properties.setProperty("group.id", "test");
DataStream<String> stream = env
- .addSource(new FlinkKafkaConsumer08<>("topic", new SimpleStringSchema(),
properties));
+ .addSource(new FlinkKafkaConsumer09<>("topic", new SimpleStringSchema(),
properties));
{% endhighlight %}
</div>
<div data-lang="scala" markdown="1">
{% highlight scala %}
val properties = new Properties()
properties.setProperty("bootstrap.servers", "localhost:9092")
-// 仅 Kafka 0.8 需要
-properties.setProperty("zookeeper.connect", "localhost:2181")
properties.setProperty("group.id", "test")
stream = env
- .addSource(new FlinkKafkaConsumer08[String]("topic", new
SimpleStringSchema(), properties))
+ .addSource(new FlinkKafkaConsumer09[String]("topic", new
SimpleStringSchema(), properties))
Review comment:
`docs/dev/datastream_api.md` and `docs/dev/datastream_api.zh.md` still
contain a reference to `FlinkKafkaConsumer08`
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
