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年前550ビュー
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
回答済み 2年前

ログインしていません。 ログイン 回答を投稿する。

優れた回答とは、質問に明確に答え、建設的なフィードバックを提供し、質問者の専門分野におけるスキルの向上を促すものです。

質問に答えるためのガイドライン

関連するコンテンツ