Class EncryptionKeyIdDeserializer

java.lang.Object
io.confluent.dekregistry.storage.serialization.EncryptionKeyIdDeserializer
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.kafka.common.serialization.Deserializer<EncryptionKeyId>

public class EncryptionKeyIdDeserializer extends Object implements org.apache.kafka.common.serialization.Deserializer<EncryptionKeyId>
  • Constructor Details

    • EncryptionKeyIdDeserializer

      public EncryptionKeyIdDeserializer()
  • Method Details

    • configure

      public void configure(Map<String,?> configs, boolean isKey)
      Specified by:
      configure in interface org.apache.kafka.common.serialization.Deserializer<EncryptionKeyId>
    • deserialize

      public EncryptionKeyId deserialize(String topic, byte[] key) throws org.apache.kafka.common.errors.SerializationException
      Specified by:
      deserialize in interface org.apache.kafka.common.serialization.Deserializer<EncryptionKeyId>
      Throws:
      org.apache.kafka.common.errors.SerializationException