KafkaMessageListenerContainer перерабатывает сообщение, если есть исключение servicedown

Question

Мы хотим, чтобы слушатель Spring Kafka был настроен таким образом, что, если какая-либо внешняя служба недоступна, мы не хотим потерять сообщение, которое потребляется от Kafka. мы хотим вернуть его обратно, пока он не будет успешно обработан.

Не могли бы вы помочь с конфигурацией, которую я могу использовать для достижения того же.

Как я могу обработать его, если я использую сообщение в партиях.

Мы используем Кафку 0,9

Answer 1

Я думаю Retry лучше всего подходит к вашим требованиям:

Чтобы повторить попытку поставки, удобные слушающих адаптеров - RetryingMessageListenerAdapter и RetryingAcknowledgingMessageListenerAdapter предоставляются в зависимости от того, используете MessageListener или AcknowledgingMessageListener.