Debezium 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.

Debezium MongoDB Source Connector allows you to capture any changes in your MongoDB database and store them as messages in your Kafka topics. In this guide, we will walk you through creating a Debezium 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 Debezium MongoDB Connector

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.

If your MongoDB database is SSL enabled, don’t forget to add "mongodb.ssl.enabled": true at this step. For example, MongoDB Atlas is always SSL enabled.

After that we can continue by clicking Connect.

Congratulations! You have created a Debezium 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 the related topic to see latest events as they are coming from Kafka.