Если вдруг кто прочитает и захочет мне помочь, то кратко

опишу:
Есть два сервиса: Производитель и Получатель. К получателю получается коннектятся клиенты и сидят на long polling, ждут когда им придет новое событие, а Производитель отправляет события. Они общаются между собой через Kafka
, но в кафке фиксированы топики и group id (получатель), а как мне организовать этму систему, чтобы подсоединенные клиенты заправшивали у kaffka есть ли у них новые сообщения ? Не получать же мне все абсолютно уведомления с kaffka этим получателем-сервером, чтобы потом выдавать подконнекченному пользователю, ведь для этого и создана kaffka.
Хотелось бы как то организовать, чтобы клиент подсоединялся и запускался процесс, который бы опрашивал kaffka о наличии сообщений именно для этого пользователя, но как, чет я хз(( или не понимаю чего

Палкой не бить, новичок, и спросить мне не у кого )

может я не туда думаю или смотрю.
Чтобы я продюсером мог бы посылать событие указывая ID пользователя, а другим сервисом опрашивать каффку используя этот ID, есть ли у него сообщения.

Мне кажется, кафка для такого слабо подходит. Лучше посмотреть в сторону RabbitMQ и routing key

я думаю можно и с кафкой это сделать, только решать кому какие сообщения отдавать будет ваш Получатель. Если несколько инстансов получателя, то каждого можно положить в свою группу, каждый будет все сообщения получать и смотреть какие клиенты у него на лонгполлинге висят, особенно неплохо, когда клиенты могут висеть на любом получателе рандомно.