Что происходит с системой когда все брокеры сломались в Kafka

При падении всех брокеров Kafka система перестаёт обрабатывать запросы:

1. Производители не смогут отправлять сообщения (ошибки LeaderNotAvailable, NotController). В зависимости от конфигурации (acks=all) записи могут теряться.

2. Потребители не смогут читать данные. Оффсеты не обновляются, но после восстановления чтение продолжится с последнего коммита.

3. Зоокипер остаётся критическим компонентом - если он жив, кластер сможет восстановиться после возврата брокеров.

Пример обработки ошибки в producer:

try {
    producer.send(new ProducerRecord<>("topic", "key", "value")).get();
} catch (ExecutionException e) {
    if (e.getCause() instanceof NotControllerException) {
        // логика retry или fallback
    }
}

Рекомендации:

• Минимум 3 брокера в продакшене
• Настройка unclean.leader.election.enable=false для гарантии консистентности
• Мониторинг ISR (In-Sync Replicas)