поведение метода потребительского опроса kafka с одноразовым вызовом

Question

Допустим, я звоню poll() только один раз с некоторым тайм-аутом вместо while(true) {...poll...}

1. Получит ли потребитель все записи из последней зафиксированной последней из доступных в одном кадре?
2. Имеет ли значение параметр времени ожидания?Например, если timeout==0 и миллионы записей, что происходит?

Answer 1

Согласно kafka-doc , по умолчанию max.poll.records равно 500

Максимальное количество записей, возвращаемых за один вызов poll().

Следовательно, каждый раз, когда вы звоните poll(), вы можете получить 500 max.poll.records=500 от последнего совершенного offset