[
https://issues.apache.org/jira/browse/FLINK-27088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17518576#comment-17518576
]
Penguin commented on FLINK-27088:
---------------------------------
Thanks for your review!
I have created a pull request in
[https://github.com/apache/flink/pull/19383|https://github.com/apache/flink/pull/19383]
for release-1.15 branches and
[https://github.com/apache/flink/pull/19382|https://github.com/apache/flink/pull/19382]
for release-1.14 branches.
> 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)
