class ConfluentSchemaRegistryDeserializer extends KafkaAvroDeserializer {

  @Override
  public Object deserialize(String s, byte[] bytes) {
    return this.deserialize(bytes, readerSchema);
  }

    ConfluentSchemaRegistryDeserializer(SchemaRegistryClient client, Schema readerSchema);

}