Потребитель Kafka: опрос из назначенного раздела, который уже был приостановлен другим потребителем

Question

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

ОБНОВЛЕНИЕ: я добавляю пример, чтобы прояснить сценарий: у нас есть два потребителя C1 и C2 в одной группе потребителей. Они подписаны на одну и ту же тему T1, которая имеет 2 раздела: P0 и P1. T1-P0 назначен для C1, тогда как T1-P1 назначен для C2. Внезапно C1 делает паузу T1-P0 (он вызывает C1.pause (T1-P0)), и через некоторое время C1 падает или закрывается. Произойдет перебалансировка, и теперь T1-P0 назначен на C2. C2 получает раздел темы, который был установлен в паузу. T1-P0 остается статусом паузы для C2? Сможет ли C2 получать сообщения от T1-P0?

Answer 1

Раздел темы будет назначен одному-единственному потребителю из группы потребителей. Я не уверен, что вы имели в виду под паузой в этом контексте. Но если для потребителя истекло время ожидания или он уже недоступен, произойдет перебалансировка, и раздел, выделенный для указанного потребителя, будет назначен другому потребителю из той же группы.

Если вы имели в виду программную приостановку потребления с использованием this api, то документ api очень ясен -

"Приостановить выборку из запрошенных разделов. Будущие вызовы poll (long) не будет возвращать никаких записей из этих разделов до тех пор, пока они не будут возобновлены с использованием возобновления (сбора). Обратите внимание, что этот метод не влияет на подписку на разделы. В частности, он не вызывает перебалансировки групп при использовании автоматического назначения . "

В этом случае для возобновления потребления необходимо программно возобновить .