Skip to main content

Create Cosmos DB Source

The Cosmos DB source connector is a Change Data Capture connector that leverages Cosmos DB's change feed. This connector will perform an initial snapshot of the data. Then, it will stream every INSERT and UPDATE operation and push the events into a Meroxa stream. Currently, the Cosmos change feed doesn't log DELETE operations.

Before creating a source connector:

  1. Setup - Setup your Cosmos DB instance and acquire the credentials needed to talk to Meroxa.
  2. Add Resource - Add a Cosmos DB resource to your Meroxa Resource.


The input for the connector is an Azure Cosmos Collection Id.

Creating Connector

Then, to configure Cosmos DB as a source:

First, you must create a new pipeline.

Then, using the CLI, you can run the following command to add a new source to a pipeline:

meroxa connector create to-cosmosdb-connector \
--from my-cosmosdb \
--input my-container-name \
--pipeline my-pipeline

The command above creates a new source connector called to-cosmosdb-connector, sets the source to a resource named my-cosmosdb, and configures the input.