Local Confluent Kafka sink to Mongo Atlas add failing

georgelza · 2024-05-21T12:30:37.828Z

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 >

georgelza · 2024-05-22T05:16:00.704Z

question, of the uri… which part is DNS lookup’d… the entire cluster0.gqtnee.mongodb.net or just gqtnee… onwards.

still stuck as i can mogosh using this string and it works… but when used as part of sink definition it fails.

georgelza · 2024-05-22T08:36:54.538Z

… also tried, same error. Stuck…

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