aws mks connection (document db)

0

Hi I cant seem to find a full example of Connector configuration for msk (sink configuration) with document db as target. Especially,Im not sure how to set the connection.uri,as it gets the default value, hence the connector creation fails Please advise Thanks, Rudi

Rudi
已提問 2 年前檢視次數 511 次
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'

AWS
支援工程師
已回答 2 年前
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

profile pictureAWS
支援工程師
AkashD
已回答 1 年前

您尚未登入。 登入 去張貼答案。

一個好的回答可以清楚地回答問題並提供建設性的意見回饋,同時有助於提問者的專業成長。

回答問題指南