Spring stream kafka: ошибка перехвата при отправке сообщения - PullRequest
Новая
       12

Spring stream kafka: ошибка перехвата при отправке сообщения

0 голосов
/ 04 октября 2019

Я хотел бы иметь возможность регистрировать одно сообщение, когда потребитель не может прочитать сообщение (после x попыток на основе механизма повторных попыток). Я посмотрел на способ, которым используется ErrorMessageSendingRecoverer, но не увидел там простого способа ввода моего собственного восстановителя.

пример: 

@StreamListener(Sink.INPUT)
public void sinkMessageIntoIris(final GenericRecord irisTaskMessage) {
   throw new RuntimeException();
}

Что-то вроде: 

consume message attempt 1 -> failed
consume message attempt 2 -> failed
consume message attempt 3 -> failed
       -> log message failed

Спасибо,

Сергей

...