Временные сбои (таймаут, недоступность зависимости, блокировка в базе, 503) — повторять с отсрочкой. Постоянные (невалидные данные, ошибка десериализации, нарушение бизнес-правила) — сразу в DLQ.
А ещё В Spring Kafka — DefaultErrorHandler с addNotRetryableExceptions
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Разделение по природе ошибки — основа всей схемы обработки сбоев. Временный сбой пройдёт при следующей попытке, поэтому повтор с задержкой оправдан. Ошибка в данных воспроизведётся всегда: повторяя её, вы жжёте ресурсы, забиваете логи и, в случае Kafka, останавливаете всю партицию, потому что смещение не двигается. Практическая рекомендация — явно классифицировать исключения в коде обработчика, а не полагаться на общий catch: список повторяемых исключений задаётся осознанно, всё остальное сразу уходит в DLQ. Отдельно стоит помнить, что при повторах обработка обязана быть идемпотентной, иначе успешный побочный эффект выполнится дважды.
Несколько верных вариантов. Подумайте, потом откройте ответ.
Что повторять и почему не всё, backoff/jitter, non-blocking retry, дизайн DLQ и redrive, идемпотентность как фундамент.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto