Какие знаешь гарантии доставки приложений в Kafka

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

1. At least once – сообщение гарантированно доставлено, но возможны дубли (если брокер не получил ack). Достигается с acks=all и retries > 0.
2. At most once – сообщение может быть потеряно, но дубли исключены. Настройки: acks=0 или retries=0.
3. Exactly once – сообщение доставляется ровно один раз. Требует enable.idempotence=true и isolation.level=read_committed для транзакций.

Пример producer с exactly once:

props.put("enable.idempotence", "true");
props.put("acks", "all");
props.put("retries", Integer.MAX_VALUE);
props.put("max.in.flight.requests.per.connection", "5");

Для потребителей важно управлять offset'ами и использовать транзакции при обработке.