Если Kafka упала, что происходит с отправкой событий?

Если Kafka упала (недоступна), то отправка событий зависит от настроек продюсера и архитектуры системы:

• Буферизация на стороне продюсера: Многие Kafka-клиенты умеют буферизовать сообщения локально и повторять попытки отправки, пока брокер не станет доступен.
• Режим синхронной или асинхронной отправки: В синхронном режиме вызов отправки блокируется до подтверждения, в асинхронном — сообщения могут накапливаться в очереди.
• Настройки ретраев и таймаутов: Продюсер может быть настроен на определенное количество попыток повторной отправки.
• Потеря сообщений: Если буфер переполнен или приложение не обрабатывает ошибки, сообщения могут быть потеряны.

Пример на Go с использованием sarama (клиент Kafka):

producer, err := sarama.NewSyncProducer(brokers, config)
if err != nil {
    // обработка ошибки создания продюсера
}

msg := &sarama.ProducerMessage{Topic: "topic", Value: sarama.StringEncoder("event data")}
partition, offset, err := producer.SendMessage(msg)
if err != nil {
    // обработка ошибки отправки (например, Kafka недоступна)
    // можно реализовать повторную отправку или логирование
}

Таким образом, при падении Kafka события не будут сразу отправлены, и без дополнительной логики они могут быть потеряны. Для надежности часто используют буферизацию, очереди или системы резервного хранения сообщений.