id: io-mongo title: MongoDB Connector sidebar_label: “MongoDB Connector” original_id: io-mongo

Sink

The MongoDB Sink Connector is used to pull messages from Pulsar topics and persist the messages to a collection.

Sink Configuration Options

NameDefaultRequiredDescription
mongoUrinulltrueThe uri of mongodb that the connector connects to (see: https://docs.mongodb.com/manual/reference/connection-string/).
databasenulltrueThe name of the database to which the collection belongs to.
collectionnulltrueThe collection name that the connector writes messages to.
batchSize100falseThe batch size of write to the collection.
batchTimeMs1000falseThe batch operation interval in milliseconds.