Два способа: блокирующий — DefaultErrorHandler с BackOff и DeadLetterPublishingRecoverer (повторы на месте, партиция ждёт); неблокирующий — @RetryableTopic: запись уходит в retry-топики с задержкой, а партиция продолжает обрабатываться.
А ещё У DLT должен быть владелец, алерт и способ переиграть сообщения
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Блокирующий повтор:
sotto@Bean
DefaultErrorHandler errorHandler(KafkaTemplate<Object, Object> t) {
var h = new DefaultErrorHandler(new DeadLetterPublishingRecoverer(t),
new ExponentialBackOff(1000, 2.0) {{ setMaxElapsedTime(30_000); }});
h.addNotRetryableExceptions(ValidationException.class);
return h;
}Запись повторяется на месте; пока идут повторы, остальные записи партиции ждут — порядок сохраняется, но долгая отсрочка задерживает поток. Повторы держат потребителя — нельзя ставить отсрочку длиннее max.poll.interval.ms.
Неблокирующий повтор:
@RetryableTopic(attempts = "4", backoff = @Backoff(delay = 1000, multiplier = 10),
exclude = ValidationException.class)
@KafkaListener(topics = "payments")
void handle(PaymentEvent e) { ... }Spring создаёт топики payments-retry-0, -retry-1, … и payments-dlt. Упавшая запись публикуется в retry-топик и будет прочитана после задержки, а основная партиция обрабатывается дальше. Цена — потеря порядка для этого ключа и больше топиков.
Что выбрать: порядок важен (события одной сущности) — блокирующий с небольшим числом попыток; порядок не важен, важна пропускная способность — неблокирующий. В обоих случаях: неповторяемые исключения — сразу в DLT, десериализация — через ErrorHandlingDeserializer, мониторинг DLT.
Один верный вариант. Подумайте, потом откройте ответ.
KafkaTemplate, @KafkaListener, listener containers, offset ack, error handling, retries и DLT.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.