Сценарий. Сторонняя система создает сообщения для определенных пользователей и отправляет их в систему промежуточного программного обеспечения. Система промежуточного программного обеспечения обрабатывает сообщения и сохраняет эти сообщения в теме Kafka под названием «MessageTopic». Теперь на другом конце есть 1000 или 10 000 растущих пользователей, которые подписались на тему для получения сообщений.
Теперь, каждое сообщение предназначено для определенного пользователя. И поэтому ожидается, что каждый пользователь должен получать только это конкретное сообщение?
Подскажите, пожалуйста, как этого добиться, используя тему Кафки? [Очевидно, что создание тысяч тем не имеет смысла в этом случае.]