Details
-
Question
-
Resolution: Works as Designed
-
Unknown
-
None
-
None
-
None
Description
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Ā ?