2回答
- 新しい順
- 投票が多い順
- コメントが多い順
1
Hello Rudi, there is currently no publicly documented solution for document db. However the basic configuration looks something like below
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
database=documentdb
tasks.max=1
topics=documentdb.Source
connection.uri=<DocumentDB uri>
collection=Sink
value.converter=org.apache.kafka.connect.storage.StringConverter
key.converter=org.apache.kafka.connect.storage.StringConverter
“connection uri” can be found on AWS DocumentDB console > select primary instance > Connectivity & Security tab > 'Connect' section > link mentioned for 'Connect to this instance with an application'
0
Hello Rudi,
Just to add to Harshith's answer, in similar way you can also configure Source connector and basic configuration will look like below
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
database=documentdb
tasks.max=1
connection.uri=<DocumentDB uri>
collection=Source
value.converter=org.apache.kafka.connect.storage.StringConverter
key.converter=org.apache.kafka.connect.storage.StringConverter
To get more details on how to create DocumentDB cluster and how to connect to it, you can follow below documentation. https://docs.aws.amazon.com/documentdb/latest/developerguide/get-started-guide.html