Обработчик исключений производителя в Spring Cloud Stream

Question

Я сталкиваюсь со сценарием в моем задании Kafka Stream, написанном в Spring Cloud Stream, где произошел сбой источника с исключением.

Проверен в потоке kafka, есть конфигурация для обработки этого с помощью: default.production.exception.handler

Невозможно найти следующий обработчик в весеннем облачном потоке. Пожалуйста, помогите. Заранее спасибо.

Версия с загрузочной пружиной: 2.2.4.RELEASE

Answer 1

default.production.exception.handler

Вы можете установить любое произвольное свойство Kafka Streams, используя свойство

spring.cloud.stream.kafka.streams.binder.configuration

.

См. the документация .

Так что просто добавьте ее туда.