kafka mongo db source connector with mongo db running on kubernetes
I am trying to setup mongo db source connector and sink connector using Mongo DB atlas URI and confluent kafka platform connector.
Sink connector was able successfully established.
but when i try to make Source connector, problem arised.
Could you possibly find my problem?
This is POST json data for http://localhost:8083/connectors
{"name": "mongo-source-cashRecord", "config": { "tasks.max":"1", "connector.class":"com.mongodb.kafka.connect.MongoSourceConnector", "topic.prefix":"mymongo_joy_", "key.converter":"org.apache.kafka.connect.json.JsonConverter", "key.converter.schemas.enable":false, "value.converter":"org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable":false, "connection.uri":"mongodb+srv://userid:password@clusterjoy.iz9ag.mongodb.net/testdb?retryWrites=true&w=majority", "database":"testdb", "collection":"cashRecord", "pipeline": "[{\"$match\":{\"operationType\":{\"$in\":[\"insert\",\"update\",\"replace\"]}}}]"}}