@ Override public synchronized MD5Digest register ( String name , Schema schema ) throws IOException , SchemaRegistryException { MD5Digest md5Digest = generateId ( schema ) ; if ( ! _schemaHashMap . containsKey ( md5Digest ) ) { _schemaHashMap . put ( md5Digest , schema ) ; _topicSchemaMap . put ( name , schema ) ; } return md5Digest ; }
Register this schema under the provided name