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

У меня есть два потребительских сервера с одинаковым идентификатором группы, которые подписались на одну и ту же тему. Сервер кафка работает только с одним разделом. Насколько мне известно, сообщение должно использоваться случайным образом на этих двух серверах-потребителях. Но теперь кажется, что всегда один и тот же сервер-потребитель A потребляет сообщения, а другой сервер не принимает сообщения. Если я остановлю сервер-получатель A, другой будет работать нормально. Я ожидаю, что они могут получать сообщения случайным образом.


apache-kafka kafka-consumer-api kafka-producer-api
person fcbflying    schedule 05.04.2016    source источник
comment
Какие факторы повлияют на приоритет сервера потребителя? сеть или что-то еще?   -  person fcbflying    schedule 05.04.2016

Ответы (1)


arrow_upward
3
arrow_downward

Чтобы иметь возможность использовать два экземпляра-потребителя параллельно, вам необходимо как минимум два раздела в теме. Потребитель будет связываться с одним или несколькими разделами темы, а другие потребители с тем же groupId не будут требовать разделы, к которым уже привязаны потребители. Если потребитель выйдет из строя / выйдет из строя, раздел будет освобожден, а затем перехвачен другим экземпляром потребителя.

person Lundahl    schedule 05.04.2016