-
Type:
Question
-
Resolution: Works as Designed
-
Priority:
Unknown
-
None
-
Affects Version/s: None
-
Component/s: CDC, Configuration, Source
-
None
So I am using Mongo kafka connector as a source and here is my config
{
"name": "MONGO_SO",
"config": {
"connector.class": "com.mongodb.kafka.connect.MongoSourceConnector",
"errors.log.include.messages": "true",
"publish.full.document.only": "true",
"tasks.max": "1",
"change.stream.full.document": "updateLookup",
"collection": "coupon",
"key.converter.schemas.enable": "false",
"topic.prefix": "",
"database": "",
"poll.await.time.ms": "5000",
"connection.uri": "",
"name": "MONGO_SOU",
"value.converter.schemas.enable": "false",
"copy.existing": "true",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"errors.log.enable": "true",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"poll.max.batch.size": "1000"
}
}
But in the events that I receive in the kafka cluster doesn't contain any operation type column. Any thing to change in config to achieve this ?