у Kafka auto commit есть синхронизация или асинхронность под капотом?

Question

Если kafka enable.auto.commit=true, значит ли это, что каждые 5 секунд он будет запускать синхронизацию или асинхронную операцию для фиксации смещения?

Может ли небольшой интервал (2 секунды) как-то повлиять на задержку?

Answer 1

На самом деле он использует оба!

«Обычный» автоматический коммит, который происходит периодически при вызове poll() с использованием async.См. 1 .

. Однако автоматическая фиксация также происходит, когда потребитель закрывается или присоединяется к группе, и в этих случаях используется синхронный режим.См. 2 или 3 .

Что касается автоматической фиксации с использованием небольшого интервала, влияющего на задержку, в большинстве случаев это маловероятно.