Kafka реплицирует каждую партицию на несколько брокеров (задается replication.factor). Один брокер является лидером партиции, остальные - репликами в ISR (In-Sync Replicas).

Механизмы отказоустойчивости

• Репликация: данные копируются на несколько брокеров; при потере одного данные не теряются
• ISR: набор реплик, полностью синхронизированных с лидером. При падении лидера контроллер выбирает нового из ISR
• acks=all: продюсер получает подтверждение только когда все ISR-реплики записали сообщение
• min.insync.replicas: минимальное число синхронных реплик для записи; защита от потери при падении нескольких брокеров

Типичная конфигурация: replication.factor=3, min.insync.replicas=2, acks=all - выдерживает потерю одного брокера без остановки и без потери данных.