Я пытаюсь реализовать приложение CometD с помощью kafka.
Сценарий использования: Я устанавливаю sh соединение cometD при отправке сообщения, которое оно публикует в Kafka Producer, пока что хорошо. У меня есть прослушиватель сервлетов для инициализации потребителя кафки и опроса сообщений от topi c. Я использую ServerSession для доставки сообщения обратно клиенту. Когда несколько потребителей из одной и той же группы опрашивают сообщения, он может опрашивать ответ, предназначенный для другого потребителя, который содержит уникальный идентификатор, на который должно быть доставлено сообщение, но он может найти его, поскольку идентификатор сеанса присутствует на другом хосте, на котором другой потребитель это работает. Может ли кто-нибудь помочь мне понять, как я могу справиться с этой ситуацией
Спасибо