Penguin created FLINK-27088:
-------------------------------
Summary: The example of using StringDeserializer for deserializing
Kafka message value as string has an error
Key: FLINK-27088
URL: https://issues.apache.org/jira/browse/FLINK-27088
Project: Flink
Issue Type: Improvement
Components: Documentation
Affects Versions: 1.14.4
Reporter: Penguin
Attachments: StringDeserializer.png
The example of using StringDeserializer for deserializing Kafka message value
as string has an error in flink's document 1.4 release, the parameters of the
example code "KafkaRecordDeserializationSchema.valueOnly()" should be
"StringDeserializer.class" rather than "StringSerializer.class".
The document link is as follows: [link
title|https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#deserializer]
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
