文档菜单
文档首页

MongoDB Kafka 连接器

关于MongoDB Connector for Apache Kafka 是一个经过 Confluent 验证的连接器,它将 Apache Kafka 主题中的数据持久化到 MongoDB,并将 MongoDB 中的更改发布到 Kafka 主题作为数据源。

我们建议您使用以下 MongoDB 合作伙伴服务之一来托管您的 Apache Kafka 集群和 MongoDB Kafka 连接器

注意

您还可以使用Atlas Stream Processing,这是通过MongoDB Query API处理流数据的MongoDB原生方式。它改变了开发者构建现代应用的方式。

使用Atlas Stream Processing持续处理流数据,验证模式,并将视图物化到Atlas数据库集合或Apache Kafka主题中。

要了解更多关于Atlas Stream Processing的信息,请参阅Atlas Stream Processing产品页面或阅读文档。

有关每个版本的新功能和更改列表,请参阅新增功能部分。

了解如何在Kafka Connector 快速入门部分开始使用MongoDB Kafka Connector,并开始处理数据。

简介部分了解MongoDB Kafka连接器如何在Apache Kafka和MongoDB之间传递数据。在此部分,您还可以了解如何安装连接器以及如何配置它以连接到您的MongoDB部署。

按照教程学习如何设置MongoDB Kafka连接器,以用于多种用例中的数据读取和写入。

接收连接器部分了解如何配置MongoDB Kafka接收连接器,以便将Apache Kafka中的数据写入MongoDB。

源连接器部分了解如何配置MongoDB Kafka源连接器如何将数据从MongoDB写入Apache Kafka。

安全和身份验证部分了解如何确保MongoDB与MongoDB Kafka连接器之间的通信安全。在此部分,您还可以了解如何配置MongoDB Kafka连接器以使用您的AWS身份和IAM凭据对MongoDB进行身份验证。

监控部分了解如何监控您的MongoDB Kafka源和目标连接器。

迁移指南中了解如何从旧版Kafka Connect MongoDB目标连接器迁移到官方MongoDB Kafka连接器。

故障排除部分了解如何在运行MongoDB Kafka连接器时解决可能出现的问题。

如何贡献部分了解如何为MongoDB Kafka连接器代码库做出贡献。

问题 & 帮助部分了解如何报告错误和请求功能。

有关MongoDB Kafka Connector与MongoDB之间兼容性的信息,请参阅兼容性部分。在此部分中,您还可以了解MongoDB Kafka Connector与Confluent Kafka Connect之间的兼容性。

下一步

新增功能