kafka mongo db source connector with mongo db running on kubernetes kafka mongo db source connector with mongo db running on kubernetes kubernetes kubernetes

kafka mongo db source connector with mongo db running on kubernetes


I think You need to setup mongodb cluster in correct way. Please follow this to deploy mongodb replica set on kuberntes using operator. If you want to setup with statefulset only follow this


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\"]}}}]"}}