Какова задержка между каждым опросом

Question

В документации kafka я пытаюсь понять это свойство max.poll.interval.ms

Максимальная задержка между вызовами poll () при использовании управления группами потребителей,Это накладывает верхнюю границу на количество времени, в течение которого потребитель может бездействовать до получения большего количества записей.Если poll () не вызывается до истечения этого тайм-аута, то потребитель считается неуспешным, и группа будет перебалансирована, чтобы переназначить разделы другому участнику.

Это означает, что каждый опрос будет проводиться доpoll-time-out по умолчанию это 5 минут.Поэтому мой вопрос состоит в том, сколько именно времени потребительского потока занимает между двумя последовательными опросами?

Например: Потребительский поток 1

Первый опрос -> с 100 записями -> обработать 100 записей (потребовалось1 минута) -> смещение отправлено потребителю

Второй опрос -> с 100 записями -> обработать 100 записей (заняло 1 минуту) -> смещение отправлено потребителем

Требуется ли время потребителямежду первым и вторым опросом?если да, то почему?и как мы можем изменить это время (предположим, что когда в теме огромные данные)

Answer 1

Непонятно, что вы подразумеваете под «взять время между»;если вы говорите о контейнере слушателя spring-kafka, то здесь нет ожидания или сна, если вы это имеете в виду.

Потребитель опрашивается сразу после фиксации смещения.

Итак,max.poll.interval.ms должно быть достаточно большим, чтобы ваш слушатель мог обработать max.poll.records (плюс немного лишнего, на всякий случай).

Но нет, между опросами не добавляются задержки, только время, которое уходит у слушателяобрабатывать результаты опроса.