oscerd opened a new issue #242:
URL: https://github.com/apache/camel-kafka-connector-examples/issues/242
Sample configuration for the MongoDB sink:
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnector
camel.sink.endpoint.operation=insert
camel.sink.endpoint.collection=testRecords
tasks.max=1
topics=org.apache.camel.kafkaconnector.mongodb.sink.CamelSinkMongoDBITCase
name=CamelMongoDBSinkConnector
value.converter=org.apache.kafka.connect.storage.StringConverter
camel.sink.path.connectionBean=mongo
camel.beans.mongo=#class:com.mongodb.client.MongoClients#create('mongodb://localhost:32772')
camel.sink.endpoint.database=testDB
key.converter=org.apache.kafka.connect.storage.StringConverter
An important bit for the mongoDB sink is to configure the camel.beans.mongo
property correctly. In this case, it is setting the bean to be created by
calling the method create passing the URL of the mongodb instance
(mongodb://localhost:32772). This should be configured accordingly to your
setup.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
