Блог

В настоящее время я работаю над небольшим проектом, в котором мне нужно подключить кластер кафки к mongodb, чтобы сообщения, опубликованные в теме кафки, хранились в базе данных mongodb. В настоящее время у меня есть локальный кластер кафки, производитель springboot, публикующий сообщения в теме, и потребитель springboot, потребляющий эти сообщения локально. Я также установил mongodb compass локально…я просматривал учебные пособия, и я понял, что для того, что я хочу сделать, мне нужно использовать какой-то разъем приемника(разъем mongodb), но большинство примеров основаны на mongodb atlas и confluent или aws, управляемых kafka…is есть какие-либо хорошие учебные пособия, которым я могу следовать, чтобы узнать, как работать с локальным кластером кафки и локальным mongodb, или если кто-нибудь из вас может объяснить мне, что делать, я буду вам очень признателен.. Спасибо.

большинство примеров основаны на атласе mongodb и кафке, управляемом confluent или aws..

Удалите все ключи доступа или проверки подлинности и просто измените bootstrap.servers строку подключения property Mongo, и любой учебник, который вы найдете, должен работать с вашими локальными установками

AFAICT, пример Docker в документации не использует никаких облачных сервисов

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