MongoDB sink connector
You can download all the Pulsar connectors on download page.
The MongoDB sink connector pulls messages from Pulsar topics and persists the messages to collections.
Configuration​
The configuration of the MongoDB sink connector has the following properties.
Property​
Name | Type | Required | Default | Description |
---|---|---|---|---|
mongoUri | String | true | " " (empty string) | The MongoDB URI to which the connector connects. For more information, see connection string URI format. |
database | String | true | " " (empty string) | The database name to which the collection belongs. |
collection | String | true | " " (empty string) | The collection name to which the connector writes messages. |
batchSize | int | false | 100 | The batch size of writing messages to collections. |
batchTimeMs | long | false | 1000 | The batch operation interval in milliseconds. |
Example​
Before using the Mongo sink connector, you need to create a configuration file through one of the following methods.
JSON
{
"configs": {
"mongoUri": "mongodb://localhost:27017",
"database": "pulsar",
"collection": "messages",
"batchSize": "2",
"batchTimeMs": "500"
}
}YAML
configs:
mongoUri: "mongodb://localhost:27017"
database: "pulsar"
collection: "messages"
batchSize: 2
batchTimeMs: 500