mongodb - 如何将本地 Kafka 集群连接到本地 Mongodb？

Question

我目前正在做一个小项目，我需要将 kafka 集群连接到 mongodb，以便将发布到 kafka 主题的消息存储在 mongodb 数据库中。我目前有一个本地 kafka 集群、一个向主题发布消息的 springboot 生产者和一个在本地消费这些消息的 springboot 消费者。我还在本地安装了 mongodb 指南针...我一直在看教程，我发现我必须使用某种接收器连接器（mongodb 连接器）来完成我想做的事情，但大多数示例都是基于在 mongodb atlas 和 confluent 或 aws 管理的 kafka 上...有没有什么好的教程我可以学习如何在本地 kafka 集群和本地 mongodb 上做，或者如果你们中的任何一个可以解释我该怎么做，我将不胜感激.. 谢谢。

标签： mongodbspring-bootapache-kafka

Answer 1

大多数示例都基于 mongodb atlas 和 confluent 或 aws managed kafka..

删除任何访问密钥或身份验证，只需修改bootstrap.servers属性 + Mongo 连接字符串，您找到的任何教程都应该适用于您的本地安装

AFAICT，文档中的 Docker 示例没有使用任何云服务

https://docs.mongodb.com/kafka-connector/current/kafka-docker-example/