Is your feature request related to a problem? Please describe.
Currently functions don't provide api for uploading public/private keys for managing e2e encryption/decryption
Describe the solution you'd like
Most obvious solution will be to expose ICryptoKeyReader to be used on source/sink creation. Implementation should be providing public and private keys.
Describe alternatives you've considered
Don't use pulsar functions and use a custom consumer/producer pair
Is your feature request related to a problem? Please describe.
Currently functions don't provide api for uploading public/private keys for managing e2e encryption/decryption
Describe the solution you'd like
Most obvious solution will be to expose ICryptoKeyReader to be used on source/sink creation. Implementation should be providing public and private keys.
Describe alternatives you've considered
Don't use pulsar functions and use a custom consumer/producer pair