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