MongoDB Kafka source connector - how reprocessed all documents from collection again

Working with Data Connectors & Integrations
1

Hi ! I use MongoDB Kafka source connector and I can’t force connector reread mongodb collection again.
I deleted and recreated connector with another name. Reseted offset. Deleted topic but nothin help me.

    class: com.mongodb.kafka.connect.MongoSourceConnector
    config:
      "connection.uri": uri
      "database": db
      "collection": "products"
      "key.converter": "org.apache.kafka.connect.storage.StringConverter"
      "value.converter": "org.apache.kafka.connect.json.JsonConverter"
      "change.stream.full.document": "updateLookup"
      "pipeline": pipline
      "mongo.errors.log.enable": "true"
      "mongo.errors.deadletterqueue.topic.name": "name
      "heartbeat.interval.ms": 30000
``
2

You need to set copy.existing flag for the task to read all documents from mongo first as opposed to reading from oplog directly. When all the mongo documents are read, the task will resume reading from oplog.