Когда вы подписываетесь на событие на Кафке я могу добавить аргумент в подписку

Question

моя система подключается к внешнему «микросервису А». (Скажем, он возвращает прогноз погодных катастроф) «микросервис А» ничего не знает относительно моей системы и пользователей. в случае, если у меня есть пользователь, который был подписан на эту услугу,

1. Можно ли подписаться на брокер сообщений с аргументом, таким как "идентификатор пользователя", поэтому, когда он вернет ответ, я смогу знать, что этот пользователь был подписан и отправить ему ответ.

1.1. Если ответ «да», то это лучшая практика, поскольку теперь у меня будут миллионы подписчиков с идентификатором пользователя вместо одной подписки, а затем извлекает всех подписавшихся пользователей и отправляет им уведомление

Что такое лучший выбор здесь?

Answer 1

Нет дальнейших прогнозов запросов, которые вы можете сделать, кроме раздела топи c. Другими словами, поиск идентификатора невозможен при сканировании topi c без фактической проверки каждой записи.

Однако вы можете использовать Stream Processing Engine для фильтрации определенных идентификаторов пользователей по разным темам для использования в последующих процессах или создать таблицу всех событий, сгруппированных по userId.

Я смогу узнать, что этот пользователь подписан, и отправить ему ответ

В API Kafka потребители сами запрашивают данные, а не "отправлено" что-нибудь