Мне нужно ваше руководство для разработки моей системы очереди сообщений.
наша архитектура
Производители: несколько экземпляров одного приложения без сохранения состояния , которое производитсообщение для различных пользователей (например, для идентификаторов пользователей говорят x, y, z, a, b).
Потребители: несколько экземпляров одного Stateful экземпляров приложения.Каждый экземпляр служит только для набора пользователей с сохранением состояния (скажем, один экземпляр приложения обслуживает пользователей x, y, а другой экземпляр служит пользователям z, a, b).
Количество пользователей можетбыть миллион
Требование:
Производитель должен направлять сообщение только конкретному экземпляру потребителя на основе идентификатора пользователя.так что другой потребительский экземпляр не получит нежелательное сообщение (пользователь, которого он не обслуживал)
В настоящее время мы используем Kafka.Так как мы не можем создать тему для каждого пользователя (так как количество пользователей велико)
возможно ли это с Kafka или любой другой очередью сообщений, такой как RabbitMQ?
Спасибо за ваше время