C D E I M N R S

C

close() - Method in class de.saly.kafka.crypto.DecryptingDeserializer

close() - Method in class de.saly.kafka.crypto.EncryptingSerializer

concatenate(byte[], byte[], byte[], byte[], byte[], byte[]) - Static method in class de.saly.kafka.crypto.SerdeCryptoBase

configure(Map<String, ?>, boolean) - Method in class de.saly.kafka.crypto.DecryptingDeserializer

configure(Map<String, ?>, boolean) - Method in class de.saly.kafka.crypto.EncryptingSerializer

crypt(byte[]) - Method in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_AES_KEY_LEN - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_HASH_METHOD - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_IGNORE_DECRYPT_FAILURES - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_NEW_KEY_MSG_INTERVAL - Static variable in class de.saly.kafka.crypto.EncryptingSerializer

CRYPTO_RSA_PRIVATEKEY_FILEPATH - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_RSA_PUBLICKEY_FILEPATH - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

CRYPTO_VALUE_DESERIALIZER - Static variable in class de.saly.kafka.crypto.DecryptingDeserializer

CRYPTO_VALUE_SERIALIZER - Static variable in class de.saly.kafka.crypto.EncryptingSerializer

D

de.saly.kafka.crypto - package de.saly.kafka.crypto

DecryptingDeserializer<T> - Class in de.saly.kafka.crypto

This is a deserialization (for the Consumer) wrapper which adds transparent end-to-end message encryption.

DecryptingDeserializer() - Constructor for class de.saly.kafka.crypto.DecryptingDeserializer

DEFAULT_TRANSFORMATION - Static variable in class de.saly.kafka.crypto.SerdeCryptoBase

deserialize(String, byte[]) - Method in class de.saly.kafka.crypto.DecryptingDeserializer

E

EncryptingSerializer<T> - Class in de.saly.kafka.crypto

This is a serialization wrapper which adds message encryption.

EncryptingSerializer() - Constructor for class de.saly.kafka.crypto.EncryptingSerializer

I

init(int, Map<String, ?>, boolean) - Method in class de.saly.kafka.crypto.SerdeCryptoBase

M

main(String[]) - Static method in class de.saly.kafka.crypto.RsaKeyGen

msgInterval - Variable in class de.saly.kafka.crypto.EncryptingSerializer

N

newInstance(Map<String, ?>, String, Class<T>) - Method in class de.saly.kafka.crypto.SerdeCryptoBase

newKey() - Method in class de.saly.kafka.crypto.EncryptingSerializer

Generate new AES key for the current thread

newKey() - Method in class de.saly.kafka.crypto.SerdeCryptoBase

Generate new AES key for the current thread

R

RsaKeyGen - Class in de.saly.kafka.crypto

RsaKeyGen() - Constructor for class de.saly.kafka.crypto.RsaKeyGen

S

SerdeCryptoBase - Class in de.saly.kafka.crypto

SerdeCryptoBase() - Constructor for class de.saly.kafka.crypto.SerdeCryptoBase

serialize(String, T) - Method in class de.saly.kafka.crypto.EncryptingSerializer

C D E I M N R S