Если при обработке сообщения из Kafka в приложении выбрасывается исключение, но само приложение не падает, то поведение зависит от способа обработки и настроек потребителя:
Что произойдёт с сообщением в Kafka если при его обработке выброшено исключение (но приложение не упало)?
Если при обработке сообщения из Kafka в приложении выбрасывается исключение, но само приложение не падает, то поведение зависит от способа обработки и настроек потребителя:
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
Условие
Что произойдёт с сообщением в Kafka если при его обработке выброшено исключение (но приложение не упало)?
Ответ
Если при обработке сообщения из Kafka в приложении выбрасывается исключение, но само приложение не падает, то поведение зависит от способа обработки и настроек потребителя:
- Автоматическое подтверждение (auto-commit): если offset уже зафиксирован, то сообщение считается обработанным, и оно не будет повторно доставлено, даже если обработка завершилась с ошибкой.
- Ручное подтверждение (manual commit): если offset не был зафиксирован до исключения, то сообщение останется необработанным, и при следующем запуске или перезапуске потребителя оно будет прочитано заново.
Таким образом, если исключение не приводит к фиксации offset, сообщение будет повторно доставлено и обработано. Если offset уже зафиксирован, сообщение потеряется с точки зрения повторной обработки.
Для надежной обработки часто используют обработку с ручным подтверждением и механизмы повторных попыток или DLQ (Dead Letter Queue) для сообщений, которые не удалось обработать.