We’ve got a collection that has field level encryption enabled and are streaming changes to this collection out to another service. I’m struggling to figure out how we setup the AutoEncryptionOptions on the underlying MongoClient used by the Kafka Connector. Since this is client encryption of the fields I believe I need to have these fields decrypted within the connector.
Is there some incantation within a .properties file I’m missing or maybe something in the config given?
I think a workaround would be to have the downstream service connect to Mongo and use the client encryption package to decrypt the field value…but I’m trying to avoid the downstream services all connecting to Mongo.