Какие знаешь гарантии доставки сообщений в Kafka

Kafka предоставляет несколько уровней гарантий доставки сообщений:

1. At least once (минимум один раз) - сообщение точно будет доставлено, но возможны дубли. Достигается при acks=all и enable.idempotence=true. Пример:

props.put("acks", "all");
props.put("enable.idempotence", "true");

2. At most once (максимум один раз) - сообщение может быть потеряно, но дублей не будет. Настройки: acks=0 или retries=0.

3. Exactly once (ровно один раз) - комбинация идемпотентности (enable.idempotence=true) и транзакций для кросс-партиционных/топиковых операций. Пример:

producer.initTransactions();
producer.beginTransaction();
producer.send(record);
producer.commitTransaction();

Гарантии зависят от настроек producer (acks, retries), broker (репликация) и consumer (ручное/автоматическое подтверждение offset). Для надежной доставки рекомендуется acks=all и репликация минимум в 3 брокера.