[FLINK-26133] Kafka Source Web Deserializer Java Code is Error

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.14.3
• Component/s: Documentation
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available

Environment

Flink 1.14.3

Language

Java

• Assignee: Unassigned
• Reporter: 十二
• Created: 14/Feb/22 14:25
• Updated: 21/Aug/23 10:35

Description

In the connectors/datastream/kafka page of flink-docs-release-1.14, there is an error in the demo code about deserializer, which uses KafkaSource.<String>builder().setDeserializer(KafkaRecordDeserializationSchema.valueOnly(StringSerializer. class));

However, in the actual test, the parameter of KafkaRecordDeserializationSchema.valueOnly() should be StringDeserializer.class

The web url is *https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#kafka-sourcefunction*

Issue Links

• links to: GitHub Pull Request #18763