Hi All, we have to implement encryption for kafka message.

1. Avro Serialization - Can be achieved.

2. Encrypt serialized message - We understand from this,  https://github.com/pegasystems/dataset-integrations there is write and reader impl class can be used. In this custom processing we can do the encryption or decryption.

Now we have a challange to pass a key dynamically to the class which will be used for encrypt or decrypt. Any suggestion or is some one had similar scenario.