MongoDB Source Connector

Kafka Connectors have been deprecated and will be removed on October, 1st 2024. Please refer to the deprecation notice for more information.

MongoDB Source Connector allows you to capture any changes in your MongoDB and store them as messages on your Kafka topics. In this guide, we will walk you through creating MongoDB Source Connector with MongoDB database to Upstash Kafka.

Get Started

Create a Kafka Cluster

If you do not have a Kafka cluster and/or topic already, follow these steps to create one.

Create the Connector

Go to the Connectors tab, and create your first connector by clicking the New Connector button.

Choose MongoDB Connector Source

Enter a connector name and MongoDB URI(connection string). Other configurations are optional. We will skip them for now.

The advanced screen is for any other configuration that the selected connector supports. At the top of this screen, you can find a link to related documentation. We can proceed with what we have and click the Connect button directly.

Congratulations! You have created your MongoDB Source Connector to Kafka. Note that no topics will be created until some data is available on the MongoDB database.

You can go to Messages section of your topic to see latest events as they are coming from Kafka.