Потребительские конфигурации - когда смещение фиксируется потребителем, когда мы устанавливаем enable.auto.commit в true

Question

Я установил для enable.auto.commit значение true, а для auto.commit.interval.ms - 10000 (т. Е. 10 секунд). Теперь мой вопрос: если потребитель получает 100 записей при первом опросе, а слушатель обрабатывает одну запись за одну, и он обрабатывает только 80 записей за 10 секунд, фиксирует ли он и увеличивает смещение на 80 или 100?

Answer 1

Зафиксированное смещение будет суммой, которая была опрошена, а не суммой, которая была обработана.

Вы захотите отключить автоматическую фиксацию и сделать это самостоятельно, если хотите гарантировать, что все записи в опросе были обработаны