there is just something about battling with something and getting it working…
below is the sink connector that worked… ![]()
As can be seen added a key converter and a value.converter.schemas.enabled: false
curl -X POST \
-H "Content-Type: application/json" \
--data '
{"name": "mongo-creator-sink",
"config": {
"connector.class":"com.mongodb.kafka.connect.MongoSinkConnector",
"connection.uri":"mongodb://localhost:27017/?directConnection=true",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": false,
"database":"MongoCom0",
"collection":"creator_salesbasket",
"topics":"mongocreator_basket"
}
}
' \
http://localhost:8083/connectors -w "\n"