[FLINK-27088] The example of using StringDeserializer for deserializing Kafka message value as string has an error

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.4
• Fix Version/s: 1.14.5, 1.15.0, 1.16.0
• Component/s: Documentation
• Labels: pull-request-available

Language

Java

• Assignee: Penguin
• Reporter: Penguin
• Created: 06/Apr/22 08:36
• Updated: 07/Apr/22 11:44
• Resolved: 07/Apr/22 11:44

Description

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: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#deserializer

Issue Links

• links to: GitHub Pull Request #19375
• links to: GitHub Pull Request #19382
• links to: GitHub Pull Request #19383