private Schema getReaderSchema()

in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/avro/AvroDeserializer.java [111:127]


    private Schema getReaderSchema(Schema writerSchema) {
        if (useGenericReader) {
            return writerSchema;
        } else {
            Class<SpecificRecord> readerClass = SpecificData.get().getClass(writerSchema);
            if (readerClass == null) {
                throw new SerializationException("cannot get a schema for a SpecificRecord");
            }
            try {
                return readerClass.newInstance().getSchema();
            } catch (InstantiationException e) {
                throw new SerializationException("cannot initialize reader schema by writerSchema class", e);
            } catch (IllegalAccessException e) {
                throw new SerializationException("not allowed initialize reader schema by writerSchema class", e);
            }
        }
    }