public int registerSchema ( Schema schema , String subject ) throws SchemaRegistryException { try { return schemaIdCache . get ( subject + schema . hashCode ( ) , ( ) -> registryClient . register ( subject , schema ) ) ; } catch ( ExecutionException e ) { throw new SchemaRegistryException ( e ) ; } }
Registers a parsed schema with the schema registry under the specified subject .