This is an automated email from the ASF dual-hosted git repository.
azagrebin pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.12 by this push:
new 3af44a7 [hotfix][kafka] Fix val declaration in scala code doc example
3af44a7 is described below
commit 3af44a795dad91557376d532140454e9ad07f248
Author: huzekang <[email protected]>
AuthorDate: Thu Nov 5 21:50:48 2020 +0800
[hotfix][kafka] Fix val declaration in scala code doc example
Closes #13947.
---
docs/dev/connectors/kafka.md | 2 +-
docs/dev/connectors/kafka.zh.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/dev/connectors/kafka.md b/docs/dev/connectors/kafka.md
index cbd5ffa..74f03e4 100644
--- a/docs/dev/connectors/kafka.md
+++ b/docs/dev/connectors/kafka.md
@@ -413,7 +413,7 @@ stream.addSink(myProducer);
{% highlight scala %}
val stream: DataStream[String] = ...
-Properties properties = new Properties
+val properties = new Properties
properties.setProperty("bootstrap.servers", "localhost:9092")
val myProducer = new FlinkKafkaProducer[String](
diff --git a/docs/dev/connectors/kafka.zh.md b/docs/dev/connectors/kafka.zh.md
index 63a379a..7c48571 100644
--- a/docs/dev/connectors/kafka.zh.md
+++ b/docs/dev/connectors/kafka.zh.md
@@ -371,7 +371,7 @@ stream.addSink(myProducer);
{% highlight scala %}
val stream: DataStream[String] = ...
-Properties properties = new Properties
+val properties = new Properties
properties.setProperty("bootstrap.servers", "localhost:9092")
val myProducer = new FlinkKafkaProducer[String](
