Mongodb – Why Debezium Mongo Source Kafka Connector produces string `after` field instead of a Json Object?
Here is my configuration I am using - { "name": "mongo-debezium-connector", "config": { "connector.class": "io.debezium.connector.mongodb.MongoDbConnector", "tasks.max": "1", "mongodb.connection.string": "mongodb://mongo:27017/?replicaSet=rs0", "database.include.list": "sample", "collection.include.list": "sample.workflows,sample.simulations", "topic.prefix": "mongo", "key.converter": "org.apache.kafka.connect.storage.StringConverter", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter.schemas.enable": true } } Here is the document that has been…