十二 created FLINK-26133:
--------------------------
Summary: Kafka Source Web Deserializer Java Code is Error
Key: FLINK-26133
URL: https://issues.apache.org/jira/browse/FLINK-26133
Project: Flink
Issue Type: Bug
Components: Documentation
Affects Versions: 1.14.3
Environment: Flink 1.14.3
Reporter: 十二
Attachments: image-2022-02-14-22-24-41-454.png
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({color:#FF0000}StringSerializer.
class{color}));*
However, in the actual test, the parameter of
*KafkaRecordDeserializationSchema.valueOnly()* should be
*StringDeserializer.class*
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
