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