public Schema loadFromRegistry ( String subject ) throws SchemaRegistryException { try { SchemaMetadata metadata = registryClient . getLatestSchemaMetadata ( subject ) ; return registryClient . getByID ( metadata . getId ( ) ) ; } catch ( IOException | RestClientException e ) { throw new SchemaRegistryException ( e ) ; } }
Loads and parses a schema for the specified subject from the schema registry