storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/JdbcStorageService.java [103:125]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if (schemaInfo == null || schemaInfo.getDetails() == null || schemaInfo.getDetails().getSchemaRecords() == null) {
            return null;
        }
        SchemaMetaInfo schemaMetaInfo = schemaInfo.getMeta();
        if (schemaMetaInfo == null) {
            return null;
        }
        if (schemaMetaInfo.getType() == SchemaType.AVRO) {
            for (SchemaRecordInfo schemaRecordInfo : schemaInfo.getDetails().getSchemaRecords()) {
                Schema store = new Schema.Parser().parse(schemaRecordInfo.getIdl());
                Schema target = new Schema.Parser().parse(qualifiedName.getSchema());
                if (Objects.equals(store, target)) {
                    return schemaRecordInfo;
                }
            }
        } else {
            //todo support other type
            return null;
        }
        return null;
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqStorageClientImpl.java [124:146]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if (schemaInfo == null || schemaInfo.getDetails() == null || schemaInfo.getDetails().getSchemaRecords() == null) {
            return null;
        }
        SchemaMetaInfo schemaMetaInfo = schemaInfo.getMeta();
        if (schemaMetaInfo == null) {
            return null;
        }
        if (schemaMetaInfo.getType() == SchemaType.AVRO) {
            for (SchemaRecordInfo schemaRecordInfo : schemaInfo.getDetails().getSchemaRecords()) {
                Schema store = new Schema.Parser().parse(schemaRecordInfo.getIdl());
                Schema target = new Schema.Parser().parse(qualifiedName.getSchema());
                if (Objects.equals(store, target)) {
                    return schemaRecordInfo;
                }
            }
        } else {
            //todo support other type
            return null;
        }
        return null;
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



