Class EncryptionKeyDeserializer

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

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

    • EncryptionKeyDeserializer

      public EncryptionKeyDeserializer()
  • Method Details

    • configure

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

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