Skip to content

Instantly share code, notes, and snippets.

@hpgrahsl
Created July 19, 2019 12:43
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save hpgrahsl/6dae22173966e786d0af0b5e1d311b2d to your computer and use it in GitHub Desktop.
Save hpgrahsl/6dae22173966e786d0af0b5e1d311b2d to your computer and use it in GitHub Desktop.
Communtiy MongoDB Sink Connector Config
{
"name": "mdb-sink-outbox-raw",
"config": {
"key.converter":"io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url":"http://localhost:8081",
"value.converter":"io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url":"http://localhost:8081",
"connector.class": "at.grahsl.kafka.connect.mongodb.MongoDbSinkConnector",
"topics": "dbserver1.outbox-demo.outbox_event",
"mongodb.connection.uri": "mongodb://localhost:27017/outboxed",
"mongodb.collections":"outbox-raw",
"mongodb.collection.dbserver1.outbox-demo.outbox_event":"outbox-raw",
"mongodb.change.data.capture.handler.outbox-raw":"at.grahsl.kafka.connect.mongodb.cdc.debezium.rdbms.RdbmsHandler",
"mongodb.change.data.capture.handler.operations.outbox-raw":"c"
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment