Используя 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);
}