MongoDB® is a NoSQL document database used for high-volume data storage. As a document store, MongoDB makes use of collections and documents rather than tables and rows. It offers a flexible data model for storing JSON-like data, and provides indexing, replication.

Getting Started

Connections come in two flavors: source and sink. Source connections read from an external system and write to a Decodable stream, while sink connections read from a stream and write to an external system. The MongoDB connector can only be used in the sink role – if you want to use MongoDB as a source, see MongoDB CDC.

Configure As A Sink

To create and configure a connector for MongoDB, sign in to the Decodable Web Console, navigate to the Connections tab, click on New Connection, and follow the steps below. For examples of using the command line tools or scripting, see the How To guides.

  1. The connector type will default to sink, since that is the only option for MongoDB connectors.
  2. Provide the connection string for your MongoDB instance. Decodable supports both Standard Connection String and DNS Seed List Connection String formats.
    Note: the connection string you provide must not contain your username & password.
  3. Provide the Database and Collection you want to ingest records to.
  4. Provide the username and password of the user on whose behalf the connection is being made.

Start the connection and observe data flow into your MongoDB instance.

Your MongoDB instance may require configuring network access from Decodable IP space. Please contact [email protected] or join our Slack community and we can provide these values to you.


Connector namemongo
Delivery guaranteeat least once
Supported stream typesappend, change


The following properties are supported by the MongoDB connector.

connection-stringrequiredMongoDB connection string without username:password set
databaserequiredDatabase containing the collection
collectionrequiredThe name of the collection to use
usernamerequiredUsername to use for authentication
passwordrequiredPassword to use for authentication