orpiske commented on issue #823:
URL:
https://github.com/apache/camel-kafka-connector/issues/823#issuecomment-753855930
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]
