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

2 réponses
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
INGÉNIEUR EN ASSISTANCE TECHNIQUE
répondu il y a 2 ans
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
INGÉNIEUR EN ASSISTANCE TECHNIQUE
AkashD
répondu il y a un an

Vous n'êtes pas connecté. Se connecter pour publier une réponse.

Une bonne réponse répond clairement à la question, contient des commentaires constructifs et encourage le développement professionnel de la personne qui pose la question.

Instructions pour répondre aux questions