You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Penguin (Jira)" <ji...@apache.org> on 2022/04/06 08:37:00 UTC

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

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)