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:39:00 UTC

[jira] [Updated] (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 ]

Penguin updated FLINK-27088:
----------------------------
    Description: 
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]

  was:
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]


> 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
>            Priority: Major
>         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)