Details
-
Improvement
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
1.14.3
-
None
-
Flink 1.14.3
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*
Attachments
Attachments
Issue Links
- links to