Что такое принцип гарантированной доставки в Kafka

Kafka обеспечивает гарантированную доставку через механизм подтверждений (acks) и репликации:

1. Acks=all – продюсер ждёт подтверждения от всех реплик перед подтверждением записи. Это гарантирует, что сообщение не потеряется даже при падении брокера.

2. Репликация – каждая партиция имеет несколько реплик на разных брокерах. Лидер синхронизирует данные с фолловерами.

3. ISR (In-Sync Replicas) – только реплики из синхронизированного набора могут стать лидерами.

Пример настройки продюсера:

props.put("acks", "all"); // Гарантированная запись
props.put("retries", 3); // Повторы при ошибках
props.put("enable.idempotence", true); // Идемпотентность

Потребитель также должен подтверждать оффсеты только после обработки сообщения (enable.auto.commit=false).