Как предотвратить пузырьки исключения после повторных перебоев с @retryabletopic в Spring Kafka ⇐ JAVA

[Anonymous]

Я использую Java 17 и приложение Spring Boot для употребления сообщений kafka с повторной обработкой через Spring Kafka.

Код: Выделить всё

@RetryableTopic(
attempts = "3",
backoff = @Backoff(delay = 1000),
kafkaTemplate = "kafkaTemplate",
listenerContainerFactory = "customKafkaListenerContainerFactory")
< /code>
@KafkaListener(
topics = "my-topic",
groupId = "my-group",
containerFactory = "customKafkaListenerContainerFactory")
< /code>
public void listen(String message) {
if (!processMessage(message)) {
throw new RuntimeException("Processing failed");
}
}

This setup successfully retries failed messages, and after exhausting all attempts, the message is sent to the Dead Letter Topic (DLT).
I want to prevent the exception from propagating or appearing as unhandled
I also tried adding a @DltHandler method to handle final failures:

Код: Выделить всё

@DltHandler
public void handleDlt(String message) {
log.warn("Message permanently failed after retries: {}", message);
}
< /code>
Этот метод вызывает правильно, когда сообщение приземляется в DLT. Хотя @dlthandler 

регистрирует неудачное сообщение, исключение по -прежнему пузырится и появляется в журналах как нездоровая ошибка. Я хочу подавить это исключение после его обработки (согласно журналам, исключение брошено до того, как @dlthandler регистрирует окончательную попытку).


Подробнее здесь: https://stackoverflow.com/questions/797 ... n-spring-k