vroyer opened a new issue #10438: URL: https://github.com/apache/pulsar/issues/10438
When the schema is not known at compile time, a `Consumer<GenericObject>` should be able to get the message schema. Currently, a `Consumer<GenericRecord>` can get the AVRO message and retreive its schema, but if the message is a KeyValue for example, there is no way to get the actual Schema. The idea is to introduce a `CompletableFuture<Schema<?>> getSchema()` in the Message API, returning null by default. The implementation classes (MessageImpl, TopicMessageImpl) could then fetch the Schema if available, and eventually keep it cached as a class member. -- 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: us...@infra.apache.org
