Skip to content

Instantly share code, notes, and snippets.

@thierryturpin
Last active October 8, 2021 11:04
Show Gist options
  • Save thierryturpin/13e0dfed36ebc5db965f610b1a3d8db8 to your computer and use it in GitHub Desktop.
Save thierryturpin/13e0dfed36ebc5db965f610b1a3d8db8 to your computer and use it in GitHub Desktop.
MongoDB sink connector
{
"config": {
"behavior.on.null.values": "ignore",
"collection": "ORDERS",
"connection.uri": "mongodb://user:password@172.31.60.87",
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
"connector.client.config.override.policy": "All",
"database": "dev",
"document.id.strategy": "com.mongodb.kafka.connect.sink.processor.id.strategy.PartialValueStrategy",
"document.id.strategy.partial.value.projection.list": "pk_order_id",
"document.id.strategy.partial.value.projection.type": "AllowList",
"max.batch.size": "100",
"tasks.max": "1",
"topics": "dev.dbo.ORDERS",
"transforms": "unwrap",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"writemodel.strategy": "com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy"
},
"name": "mongodb-dbo-orders"
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment