This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new eec5d45d62c [FLINK-27088][Documentation] Fix the example of using
StringDeserializer for deserializing Kafka message value as string
eec5d45d62c is described below
commit eec5d45d62c8991bdf7975ef9698e3b3308313cd
Author: zp <764028...@qq.com>
AuthorDate: Thu Apr 7 11:32:09 2022 +0800
[FLINK-27088][Documentation] Fix the example of using StringDeserializer
for deserializing Kafka message value as string
---
docs/content/docs/connectors/datastream/kafka.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/content/docs/connectors/datastream/kafka.md
b/docs/content/docs/connectors/datastream/kafka.md
index da7ac1c92df..9ad2a558001 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
