3 / 3
May 2024

Anyone have any idea why the below would be failing?
I can connect using mongosh from local machine to this end point. This is being added to a local
Confluent Kafka cluster, if I run the sink form local Kafka to local Mongo then it works.

curl -X POST \ -H "Content-Type: application/json" \ --data ' {"name": "mongo-cloud-creator-payments-sink", "config": { "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector", "connection.uri":"mongodb+srv://adminuser:password@Cluster0.gqtneeaxe.mongodb.net", "key.converter": "org.apache.kafka.connect.storage.StringConverter", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable": false, "database":"MongoCom0", "collection":"creator_salespayments", "topics":"mongocreator_payments" } } ' \ http://localhost:8083/connectors -w "\n"

{“error_code”:400,“message”:“Connector configuration is invalid and contains the following 1 error(s):\nUnable to connect to the server.\nYou can also find the above list of errors at the endpoint /connector-plugins/{connectorType}/config/validate”}
g-mbp.local:/Users/george/Desktop/MongoCreater/goProd >

… also tried, same error. Stuck… :frowning:

curl -X POST \ -H "Content-Type: application/json" \ --data ' {"name": "mongo-cloud-creator-payments-sink", "config": { "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector", "connection.uri":"mongodb+srv://username:password@cluster0.gqtnxxxx.mongodb.net/Cluster0", "key.converter": "org.apache.kafka.connect.storage.StringConverter", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable": false, "database":"MongoCom0", "collection":"creator_salespayments", "topics":"mongocreator_payments" } } ' \ http://localhost:8083/connectors -w "\n