Что такое параметр Kafka acks и какие у него значения?

acks задаёт, какого подтверждения записи ждёт producer: 0 — не ждёт, 1 — подтверждение лидера, all/−1 — подтверждение всех текущих in-sync replicas.

Короткий ответ

Что ответить на собеседовании

acks задаёт, какого подтверждения записи ждёт producer: 0 — не ждёт, 1 — подтверждение лидера, all/−1 — подтверждение всех текущих in-sync replicas.

Подробный разбор

Ответ с пояснениями

acks задаёт, какого подтверждения записи ждёт producer: 0 — не ждёт, 1 — подтверждение лидера, all/−1 — подтверждение всех текущих in-sync replicas.

acks=0 не подтверждает даже получение брокером. При acks=1 потеря лидера до репликации может потерять уже подтверждённую запись. acks=all работает вместе с min.insync.replicas: при недостаточном ISR запись отклоняется, а не становится автоматически безопасной на любом числе реплик. Это подтверждение сохранения в Kafka, не успешной бизнес-обработки consumer. Для безопасных повторов отдельно учитывают idempotent producer; acks сам по себе не устраняет все дубликаты end-to-end.

Источник: Документация Apache Kafka.

ИИ-помощник для собеседований

Хочешь уверенно проходить собеседования?

Попробуй ИИ-помощник для собеседований: слышит вас и собеседника, анализирует экран, подсказывает ответы в реальном времени, работает без VPN и не попадает в захват экрана.

Подробнее