Учитывая тот факт, что Consumer в Kafka может быть настроен на получение сообщений только из одного раздела, я не видел подходов к настройке для этого.
Как мне сказать брокеру Kafka:
Что я ПОТРЕБИТЕЛЬ A с этим идентификатором в этой ГРУППЕ L, подписываюсь на ТЕМУ X, желаю получить поток РАЗДЕЛ А?
А затем запустите еще один ПОТРЕБИТЕЛЬ Б в ГРУППЕ L, который подписывается на ТЕМУ X, желая получить поток РАЗДЕЛЕНИЯ Б ?
Другими словами, как в сценарии, описанном Кафкой,
Как заставить потребителя подписаться на ленту на стене конкретного пользователя? Могу ли я запустить потребителя, когда пользователь входит в систему, потреблять его / ее раздел из темы и отправлять фид клиенту?
