[FLINK-22713][docs] Correct document syntax errors in Kafka page (apa…

…che#15957)
kaicao · May 21, 2021 · 1938f63 · 1938f63
1 parent 17d5643
commit 1938f63
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/docs/content.zh/docs/connectors/datastream/kafka.md b/docs/content.zh/docs/connectors/datastream/kafka.md
@@ -315,7 +315,7 @@ properties.setProperty("group.id", "test");
 FlinkKafkaConsumer<String> myConsumer =
     new FlinkKafkaConsumer<>("topic", new SimpleStringSchema(), properties);
 myConsumer.assignTimestampsAndWatermarks(
-    WatermarkStrategy.
+    WatermarkStrategy
         .forBoundedOutOfOrderness(Duration.ofSeconds(20)));
 
 DataStream<String> stream = env.addSource(myConsumer);
@@ -330,7 +330,7 @@ properties.setProperty("group.id", "test")
 val myConsumer =
     new FlinkKafkaConsumer("topic", new SimpleStringSchema(), properties);
 myConsumer.assignTimestampsAndWatermarks(
-    WatermarkStrategy.
+    WatermarkStrategy
         .forBoundedOutOfOrderness(Duration.ofSeconds(20)))
 
 val stream = env.addSource(myConsumer)
@@ -364,7 +364,7 @@ properties.setProperty("bootstrap.servers", "localhost:9092");
 
 FlinkKafkaProducer<String> myProducer = new FlinkKafkaProducer<String>(
         "my-topic",                  // 目标 topic
-        new SimpleStringSchema()     // 序列化 schema
+        new SimpleStringSchema(),    // 序列化 schema
         properties,                  // producer 配置
         FlinkKafkaProducer.Semantic.EXACTLY_ONCE); // 容错
 

diff --git a/docs/content/docs/connectors/datastream/kafka.md b/docs/content/docs/connectors/datastream/kafka.md
@@ -338,7 +338,7 @@ properties.setProperty("group.id", "test");
 FlinkKafkaConsumer<String> myConsumer =
     new FlinkKafkaConsumer<>("topic", new SimpleStringSchema(), properties);
 myConsumer.assignTimestampsAndWatermarks(
-    WatermarkStrategy.
+    WatermarkStrategy
         .forBoundedOutOfOrderness(Duration.ofSeconds(20)));
 
 DataStream<String> stream = env.addSource(myConsumer);
@@ -353,7 +353,7 @@ properties.setProperty("group.id", "test")
 val myConsumer =
     new FlinkKafkaConsumer("topic", new SimpleStringSchema(), properties);
 myConsumer.assignTimestampsAndWatermarks(
-    WatermarkStrategy.
+    WatermarkStrategy
         .forBoundedOutOfOrderness(Duration.ofSeconds(20)))
 
 val stream = env.addSource(myConsumer)