I am running Kafka Source Connector with the intention to extract existing mongo data to Kafka.
I am following the connector documentation and setting the property copy.existing to true. The connector is working fine for data events after the connector initialises (topic is created, new events coming from event stream show up in the topic), BUT no messages related to existing mongo data (either in new topics or the topic configured in the connector) can be seen in Kafka. Does anyone have a clue of why this is happening?
Kafka Connect log does not show any errors. Thank you.
Here's the connector configuration:
{"connector.class": "com.mongodb.kafka.connect.MongoSourceConnector","database": "testuk","topic.prefix": "testing4","name": "MongoSourceTest3","connection.uri": "mongodb://localhost:27017","copy.existing": "true","collection": "assignedTreatmentPlan"}