Hi All,
I am having a real problem with
“change.data.capture.handler”: “com.mongodb.kafka.connect.sink.cdc.mongodb.ChangeStreamHandler”,
Whenever I put this instruction in the connector config, it cannot create the MongoDB target collection specified by “collection”: “coll_target”,
And there is no error at all in the kafka connect log, it even seems the sink connector does not log at all the requests it is performing against the MongoDB replica set that I am using. And I see the topic offsets are being consumed, lag=0 for the connector consumer group, but the creation of the Collection on the Mongo side never happens. If I remove that instruction, all works perfectly , coll_target is created with no issue on the MongoDB side. I am running MongoSinkDB 1.6.1 and Confluent 6.2.2
Not sure where is the issue ?, by the way it used to work properly, it just suddenly stopped working.
Thank you.