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
asked 3 months ago133 views
2 Answers
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'

SUPPORT ENGINEER
answered 3 months ago
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 picture
SUPPORT ENGINEER
AkashD
answered 2 months ago

You are not logged in. Log in to post an answer.

A good answer clearly answers the question and provides constructive feedback and encourages professional growth in the question asker.

Guidelines for Answering Questions