imaffe commented on a change in pull request #18406:
URL: https://github.com/apache/flink/pull/18406#discussion_r808942533



##########
File path: docs/content/docs/connectors/datastream/pulsar.md
##########
@@ -149,11 +149,14 @@ Pulsar connector would filter the available topics by the 
`RegexSubscriptionMode
 ### Deserializer
 
 A deserializer (Deserialization schema) is required for parsing Pulsar 
messages. The deserializer is
-configured by `setDeserializationSchema(PulsarDeserializationSchema)`.
-The `PulsarDeserializationSchema` defines how to deserialize a Pulsar 
`Message<byte[]>`.
+configured by `setDeserializationSchema(PulsarDeserializationSchema)`. Pulsar 
Connector supports use [pulsar schema 
evoluiton](https://pulsar.apache.org/docs/en/schema-evolution-compatibility/)
+The `PulsarDeserializationSchema` defines how to deserialize a Pulsar Message. 
If use
+`pulsarSchema`, then pulsar client will receive deserialized `Message<T>` 
directly instead of `Message<byte[]>`. If
+using flink schema, pulsar client will receive `Message<byte[]>`.

Review comment:
       Add Chinese documentation changes




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to