tisonkun commented on code in PR #12: URL: https://github.com/apache/flink-connector-pulsar/pull/12#discussion_r1063389538
########## docs/content/docs/connectors/datastream/pulsar.md: ########## @@ -213,6 +213,8 @@ If only the raw payload of a message (message data in bytes) is needed, you can use the predefined `PulsarDeserializationSchema`. Pulsar connector provides three implementation methods. - Decode the message by using Pulsar's [Schema](https://pulsar.apache.org/docs/en/schema-understand/). + If using KeyValue type or Struct types, the pulsar `Schema` does not contain type class info which + is needed by `PulsarSchemaTypeInformation`. So we provide two more APIs to pass the type info. Review Comment: ```suggestion If using KeyValue type or Struct types, the pulsar `Schema` does not contain type class info. But it is still needed to construct `PulsarSchemaTypeInformation`. So we provide two more APIs to pass the type info. ``` -- 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]
