in commons/src/main/java/com/epam/eco/schemacatalog/client/MockExtendedSchemaRegistryClient.java [418:441]
private BasicSchemaInfo retrieveSchemaAndConvertToInfo(
String subject,
Integer version,
Consumer<BasicSchemaInfo> initConsumer) {
SchemaMetadata schemaMetadata;
if (version == null) {
try {
schemaMetadata = getLatestSchemaMetadata(subject);
} catch (Exception e) {
throw new RuntimeException(e);
}
} else {
try {
schemaMetadata = super.getSchemaMetadata(subject, version);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
BasicSchemaInfo schemaInfo = toSchemaInfo(subject, schemaMetadata);
if (initConsumer != null) {
initConsumer.accept(schemaInfo);
}
return schemaInfo;
}