如何将本地Kafka集群接入本地Mongodb？

Question

我目前正在做一个小项目，我需要将kafka集群连接到mongodb，以便将发布到kafka主题的消息存储在mongodb数据库中。我目前有一个本地kafka集群，一个springboot生产者发布消息到一个主题，一个springboot消费者在本地消费这些消息。我也在本地安装了mongodb compass…我一直在看教程，我想我必须使用某种类型的接收器连接器( mongodb连接器)来做我想做的事情，但大多数示例都是基于mongodb atlas和confluent或亚马逊网络服务托管的kafka...is，有任何好的教程我可以学习如何在本地kafka集群和本地mongodb上做，或者如果你们中的任何一个能解释我该做什么，我将非常感谢。谢谢。

Answer 1

大多数示例都是基于mongodb atlas和confluent或aws管理的kafka。

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

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

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