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);
}
}
}