You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by GitBox <gi...@apache.org> on 2021/01/04 08:22:13 UTC
[GitHub] [camel-kafka-connector] oscerd opened a new issue #823: Add Mongodb examples
oscerd opened a new issue #823:
URL: https://github.com/apache/camel-kafka-connector/issues/823
To camel-kafka-connector-examples repo
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd commented on issue #823: Add Mongodb examples
Posted by GitBox <gi...@apache.org>.
oscerd commented on issue #823:
URL: https://github.com/apache/camel-kafka-connector/issues/823#issuecomment-760927387
Moved to https://github.com/apache/camel-kafka-connector-examples/issues/242
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [camel-kafka-connector] orpiske commented on issue #823: Add Mongodb examples
Posted by GitBox <gi...@apache.org>.
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:
users@infra.apache.org
[GitHub] [camel-kafka-connector] oscerd closed issue #823: Add Mongodb examples
Posted by GitBox <gi...@apache.org>.
oscerd closed issue #823:
URL: https://github.com/apache/camel-kafka-connector/issues/823
----------------------------------------------------------------
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:
users@infra.apache.org