Пользователи могут подписаться на некоторые категории продуктов.
Все подписки хранятся в коллекции MongoDb.
Когда новый продукт добавляется в Kafka topi c Мне нужно присоединить его к существующему подписки и создать поток, который объединяет product.category со всеми пользователями, которые подписаны, и помещает его в новый топи c.
Моя проблема, как это сделать с MongoDb? Следует ли мне загружать данные о подписках на Kafka topi c и присоединяться к потоку продуктов с Subscriptions topi c?
Я не знаю, какие случаи использовать:
- Использовать MongoDb в качестве исходных данных
- Создавать повторяющиеся данные и помещать их в Kafka, когда данные вставляются в Mongodb
- Используйте только таблицы Kafka для хранения подписок, не используйте MongoDb