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

​

Example

Before using the Mongo sink connector, you need to create a configuration file through one of the following methods.

• JSON
  {
      "mongoUri": "mongodb://localhost:27017",
      "database": "pulsar",
      "collection": "messages",
      "batchSize": "2",
      "batchTimeMs": "500"
  }
  
• YAML
  {
      mongoUri: "mongodb://localhost:27017"
      database: "pulsar"
      collection: "messages"
      batchSize: 2
      batchTimeMs: 500
  }