code: public static ConfluentRegistryAvroDeserializationSchema<GenericRecord> forGeneric(Schema schema, String url,
  			int identityMapCapacity) {
  		return new ConfluentRegistryAvroDeserializationSchema<>(
  			GenericRecord.class,
  			schema,
  			new CachedSchemaCoderProvider(url, identityMapCapacity));
  	}
docs: Creates {@link ConfluentRegistryAvroDeserializationSchema} that produces {@link GenericRecord}
  using provided reader schema and looks up writer schema in Confluent Schema Registry.
  
  @param schema              schema of produced records
  @param url                 url of schema registry to connect
  @param identityMapCapacity maximum number of cached schema versions (default: 1000)
  @return deserialized record in form of {@link GenericRecord}