Фон:
Я хочу запустить клиент websocket при получении сообщения kafka. С двумя экземплярами сервера websocket это создает проблему, заключающуюся в том, что раздел kafka не нужно коррелировать с экземпляром сервера, обслуживающим точного клиента websocket.
Kafka topi c уже заполнен сообщениями с несколькими разделами. Меня не интересует сброс смещений и реальный «фиксация журнала как источника правды». В этом случае kafka используется только для передачи триггера клиенту веб-сокета
Что мне нужно:
Мое намерение состоит в том, чтобы обойти естественное разбиение в рамках той же группы потребителей. Я хотел бы получать сообщения от всех разделов на всех экземплярах одного и того же идентификатора группы. Поэтому я хочу дубликаты. Я использую весеннее облако на вершине кафки.