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

Я новичок в Spring-Kafka и пытаюсь реализовать повторную попытку в случае сбоя или любого исключения во время обработки сообщений kafka с использованием Spring Kafka RetryTemplate. Я использовал следующий код: // Это KafkaListenerContainerFactory:...