T - The type to be deserialized from (applied to the wrapped deserializer)public class DecryptingDeserializer<T> extends SerdeCryptoBase implements org.apache.kafka.common.serialization.Deserializer<T>
EncryptingSerializer
Configuration
See EncryptingSerializer on how encryption works.
This class will auto detect if an incoming message is encrypted. If not then no decryption attempt is made and message gets handled normally.
Note: As Consumers are not multithreading-safe this deserializer is also not thread-safe
| Modifier and Type | Field and Description |
|---|---|
static String |
CRYPTO_VALUE_DESERIALIZER |
CRYPTO_AES_KEY_LEN, CRYPTO_HASH_METHOD, CRYPTO_IGNORE_DECRYPT_FAILURES, CRYPTO_RSA_PRIVATEKEY_FILEPATH, CRYPTO_RSA_PUBLICKEY_FILEPATH, DEFAULT_TRANSFORMATION| Constructor and Description |
|---|
DecryptingDeserializer() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
configure(Map<String,?> configs,
boolean isKey) |
T |
deserialize(String topic,
byte[] data) |
concatenate, crypt, init, newInstance, newKeypublic static final String CRYPTO_VALUE_DESERIALIZER
public DecryptingDeserializer()
public void configure(Map<String,?> configs, boolean isKey)
configure in interface org.apache.kafka.common.serialization.Deserializer<T>public T deserialize(String topic, byte[] data)
deserialize in interface org.apache.kafka.common.serialization.Deserializer<T>kafka-end-2-end-encryption