Apache Kafka is a popular open-source distributed streaming platform for building real-time data pipelines and high-throughput applications in a fault-tolerant and scalable manner. This section of our guide will provide you with a summary of the Kafka Connectors related to MongoDB, which helps you to effectively stream data between Kafka and MongoDB.


Kafka Connect is a powerful framework, part of Apache Kafka, for integrating with external systems like databases, key-value stores, or search indexes through connectors. MongoDB Kafka Connectors allow you to transfer data between the MongoDB Atlas or self-managed MongoDB clusters and Kafka clusters seamlessly.

MongoDB Source Connector

The MongoDB Source Connector streams the data changes (inserts, updates, deletes, and replacements) within the MongoDB cluster into Kafka in real-time. This is particularly useful when you want to process, analyze, or distribute the updates happening within your MongoDB cluster to different Kafka consumers.

MongoDB Sink Connector

The MongoDB Sink Connector enables the transfer of data from a Kafka topic to MongoDB by consuming Kafka records and inserting them into the specified MongoDB collection. This can be used to store the result of stream processing or any other transformations applied to the data coming from Kafka into MongoDB, serving as the final data persistence layer.

Key Features

Getting Started

To get started with MongoDB Kafka connectors, you can follow these steps:

For a complete tutorial and detailed configuration options, refer to the official documentation.

In conclusion, MongoDB Kafka Connectors allow you to integrate MongoDB and Kafka seamlessly, enabling real-time data streaming and processing. By using these connectors, you can effectively build scalable, fault-tolerant, and resilient data pipelines between the two technologies.