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