eolivelli opened a new pull request #8854: URL: https://github.com/apache/pulsar/pull/8854
- extract original Schema from the message read from the topic - expose the schema to the PulsarRecord implement - add unit test ### Motivation Pulsar sinks cannot access the original Schema of the Message they are consuming, this is because currently PulsarSource does not publish the Schema information to downstream processing. ### Modifications Try to retrieve Schema information from the Message and push it down to the Record. ### Verifying this change - [X] Make sure that the change passes the CI checks. - [X[ This change added tests and can be verified as follows: - added unit test - tested manually with Pulsar Standalone ### Does this pull request potentially affect one of the following parts: yes with this change Pulsar function users and especially Pulsar I/O Sinks will be able to inspect the original schema in case the processing starts from a Pulsar topic (PulsarSource) ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
