[pulsar-kafka] Support encryption for pulsar-kafka producer/consumer - Githubissues

apache / pulsar-adapters

Apache Pulsar Adapters

https://pulsar.apache.org/

24 stars 31 forks source link

[pulsar-kafka] Support encryption for pulsar-kafka producer/consumer #26

Closed rdhabalia closed 3 years ago

rdhabalia commented 3 years ago

Motivation

Add ecryption support to pulsar-kafka producer and consumer.

Modification

Added Factory class CryptoKeyReaderFactory to create Pulsar::CryptoKeyReader based on configuration passed in properties.
CryptoKeyReaderFactory also allows Pulsar-kafka producer to retrieve Encryption keys.

Result

User can enable encryption by implementing CryptoKeyReaderFactory which can create CryptoKeyReader to encrypt in pulsar-kafka producer/consumer.