[flink] branch release-1.15 updated: [FLINK-27088][Documentation] Fix the example of using StringDeserializer for deserializing Kafka message value as string

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new c0c8b53a971 [FLINK-27088][Documentation] Fix the example of using 
StringDeserializer for deserializing Kafka message value as string
c0c8b53a971 is described below

commit c0c8b53a9713d692fc9c1547b41731f5e892d178
Author: zp <764028...@qq.com>
AuthorDate: Thu Apr 7 12:11:36 2022 +0800

    [FLINK-27088][Documentation] Fix the example of using StringDeserializer 
for deserializing Kafka message value as string
---
 docs/content.zh/docs/connectors/datastream/kafka.md | 2 +-
 docs/content/docs/connectors/datastream/kafka.md    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/docs/content.zh/docs/connectors/datastream/kafka.md 
b/docs/content.zh/docs/connectors/datastream/kafka.md
index caecbfe3025..39010fbf791 100644
--- a/docs/content.zh/docs/connectors/datastream/kafka.md
+++ b/docs/content.zh/docs/connectors/datastream/kafka.md
@@ -102,7 +102,7 @@ Kafka Source 提供了 3 种 Topic / Partition 的订阅方式：
 import org.apache.kafka.common.serialization.StringDeserializer;
 
 KafkaSource.<String>builder()
-        
.setDeserializer(KafkaRecordDeserializationSchema.valueOnly(StringSerializer.class));
+        
.setDeserializer(KafkaRecordDeserializationSchema.valueOnly(StringDeserializer.class));
 ```
 
 ### 起始消费位点
diff --git a/docs/content/docs/connectors/datastream/kafka.md 
b/docs/content/docs/connectors/datastream/kafka.md
index 8a623fc589b..8a1fbede6a0 100644
--- a/docs/content/docs/connectors/datastream/kafka.md
+++ b/docs/content/docs/connectors/datastream/kafka.md
@@ -103,7 +103,7 @@ Kafka message value as string:
 import org.apache.kafka.common.serialization.StringDeserializer;
 
 KafkaSource.<String>builder()
-        
.setDeserializer(KafkaRecordDeserializationSchema.valueOnly(StringSerializer.class));
+        
.setDeserializer(KafkaRecordDeserializationSchema.valueOnly(StringDeserializer.class));
 ```
 
 ### Starting Offset