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