code: public static <T extends SpecificRecord> ConfluentRegistryAvroDeserializationSchema<T> forSpecific(Class<T> tClass,
  			String url, int identityMapCapacity) {
  		return new ConfluentRegistryAvroDeserializationSchema<>(
  			tClass,
  			null,
  			new CachedSchemaCoderProvider(url, identityMapCapacity)
  		);
  	}
docs: Creates {@link AvroDeserializationSchema} that produces classes that were generated from avro
  schema and looks up writer schema in Confluent Schema Registry.
  
  @param tClass              class of record to be produced
  @param url                 url of schema registry to connect
  @param identityMapCapacity maximum number of cached schema versions (default: 1000)
  @return deserialized record