I’m trying to use MongoSink to write messages to a Mongodb collection. It’s working fine if the cluster does not have SSL/TLS enabled. If I enabled TLS/SSL the sink will not work, because doesn’t have SSL context configured.

I was checking the code inside MongoWriter and I saw that mongoClient is initialized just using connection URI

// Initialize the mongo client.
this.mongoClient = MongoClients.create(connectionOptions.getUri());

I’ve tested a dedicated mongo client with the SSL settings applyToSslSettings and i was abled to connect without problems.

Anyone knows how i can handler with this problem on Mongo Sink?

Thanks