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

Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2022/04/06 10:56:00 UTC

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

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

Martijn Visser reassigned FLINK-27088:
--------------------------------------

    Assignee: Penguin

> 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
>         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)