Gymterview
junior

Для чего нужны методы subscribe() и poll()?

subscribe() — подписка потребителя на один или несколько топиков. Этот метод не извлекает данные, а только регистрирует интерес.

poll() — извлечение данных из подписанных топиков. Возвращает записи, опубликованные с момента последнего запроса. Обычно вызывается в бесконечном цикле для непрерывного получения данных.

На собеседовании: poll() — это не только чтение данных. Внутри poll происходит: отправка heartbeat, участие в rebalancing, авто-коммит offset (если включён). Поэтому важно вызывать poll() регулярно — долгая пауза приведёт к тому, что координатор считает потребителя мёртвым.