Какие семантики доставки сообщений есть в Kafka?

В Apache Kafka существуют три основных семантики доставки сообщений:

1. At most once (не более одного раза) — сообщение может быть доставлено 0 или 1 раз. Это означает, что сообщения могут быть потеряны, но не продублированы. Обычно достигается при автоматическом подтверждении (auto-commit) оффсетов без дополнительной обработки.

2. At least once (минимум один раз) — сообщение гарантированно будет доставлено, но может быть доставлено несколько раз (дубликаты возможны). Это наиболее распространённая семантика в Kafka, когда потребитель подтверждает обработку сообщения после его получения.

3. Exactly once (ровно один раз) — сообщение доставляется ровно один раз без дубликатов и потерь. В Kafka это достигается с помощью транзакций и идемпотентного продюсера, что позволяет атомарно записывать сообщения и обновлять оффсеты.

Пример использования идемпотентного продюсера для exactly-once:

Properties props = new Properties();
props.put("enable.idempotence", "true");
KafkaProducer<String, String> producer = new KafkaProducer<>(props);
// далее отправляем сообщения

Таким образом, выбор семантики зависит от требований к надежности и производительности системы.