Skip to main content

MongoDB Connector

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.