dmcarver commented on issue #11288:
URL: https://github.com/apache/pulsar/issues/11288#issuecomment-896818246
I've been attempting o do some troubleshooting on this, and it seems that
batched messages do not have the schema version set. Thus the logic in
`org.apache.pulsar.client.impl.MessageImpl` to load the schema and deserialize
fails. Specifically `getSchemaVersion()` returns null.
The schema itself does appear to be present; if I print it out in
`receiveIndividualMessagesFromBatch()` from
`org.apache.pulsar.client.impl.ConsumerImpl` I can see output like
`AUTO_CONSUME({schemaVersion=,schemaType=BYTES}{schemaVersion=org.apache.pulsar.common.protocol.schema.LatestVersion@2922965a,schemaType=JSON})`.
It's just the version that seems to be missing.
--
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]
