commitSync блокирует и повторяет до успеха или неустранимой ошибки — надёжно, но медленнее. commitAsync не ждёт и не повторяет — быстро, но ошибки нужно обрабатывать в callback.
А ещё В Spring Kafka это скрыто за AckMode
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
commitSync() отправляет offset и ждёт ответа координатора, повторяя при временных ошибках. Поток стоит на время запроса — при коммите после каждого сообщения это заметно снижает пропускную способность.
commitAsync() отправляет и сразу возвращается; результат приходит в callback. Не повторяет при ошибке намеренно: если повторить коммит offset 100 после того, как уже прошёл коммит offset 200, позиция откатится назад. Ошибки логируют или повторяют только если номер последовательности совпадает с последним.
Типичная схема:
sottocommitAsync() после каждой пачки;finally при закрытии потребителя и в onPartitionsRevoked при ребалансе — commitSync(), чтобы зафиксировать обработанное до передачи партиций.Что коммитят: offset следующего ожидаемого сообщения, то есть последний обработанный + 1. Можно коммитить явно по партициям (Map<TopicPartition, OffsetAndMetadata>).
Частота — компромисс: реже коммит — меньше нагрузка, но больше повторной обработки после сбоя.
Один верный вариант. Подумайте, потом откройте ответ.
Группа и распределение партиций, poll-цикл, heartbeat и таймауты, модели commit offset, ребаланс и роль идемпотентности.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.