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

["Martijn Visser (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-27088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Martijn Visser closed FLINK-27088.
----------------------------------
    Fix Version/s: 1.15.0
                   1.16.0
                   1.14.5
       Resolution: Fixed

Fixed in

master: 6931bad724ec3939f2daf0e3177349879fb2e667
release-1.15: c0c8b53a9713d692fc9c1547b41731f5e892d178
release-1.14: eec5d45d62c8991bdf7975ef9698e3b3308313cd

> 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
>            Assignee: Penguin
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0, 1.16.0, 1.14.5
>
>         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: [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/kafka/#deserializer|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)