Как отключить вывод на консоль необработанных исключений из потоков в Spring Cloud Stream? - PullRequest
3 голосов
/ 28 февраля 2020

Используя Spring Cloud Stream и механизм связывания Кафки, у меня есть очень простой Процессор, связанный с потоком СИ:

    @Bean
    @Autowired
    public IntegrationFlow inputFlow(Thrower thrower) {
        return IntegrationFlows
            .from(ApplicationBinding.INPUT)
            .handle(thrower))
            .channel("nullChannel")
            .get()
    }

Бин thrower просто создает RuntimeException.

Кажется, RuntimeException обернут MessageProcessingException и выгружен на консоль.

Как я могу отключить вывод на консоль и сохранить все остальные действия такими же?

Я настроил spring.cloud.stream.bindings.error.destination=errorChannel но привязка обработчика к этому (вроде так), похоже, не дает мне никаких событий для игры:

    @ServiceActivator(inputChannel = "errorChannel")
    public void errors(ErrorMessage em) {
        log.info("Heyooo {}", em);
    }
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...