You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/10/07 06:21:04 UTC
[flink] 01/02: [hotfix] Fix typo,'Kafka' corrected to 'Kafka'
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3f0b979b6e002d6a3cfafa285be4990c72b8f10d
Author: qianchutao <17...@163.com>
AuthorDate: Mon Sep 27 00:35:19 2021 +0800
[hotfix] Fix typo,'Kafka' corrected to 'Kafka'
---
docs/content/docs/connectors/datastream/kafka.md | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/docs/content/docs/connectors/datastream/kafka.md b/docs/content/docs/connectors/datastream/kafka.md
index 8de761e..30e028d 100644
--- a/docs/content/docs/connectors/datastream/kafka.md
+++ b/docs/content/docs/connectors/datastream/kafka.md
@@ -89,7 +89,7 @@ Kafka source provide 3 ways of topic-partition subscription:
```
### Deserializer
A deserializer is required for parsing Kafka messages. Deserializer (Deserialization schema) can be
-configured by ```setDeserializer(KakfaRecordDeserializationSchema)```, where
+configured by ```setDeserializer(KafkaRecordDeserializationSchema)```, where
```KafkaRecordDeserializationSchema``` defines how to deserialize a Kafka ```ConsumerRecord```.
If only the value of Kafka ```ConsumerRecord``` is needed, you can use