Обработка ошибок EmitterProcessor - маршрутизация событий Spring Cloud Stream

Question

Я использую EmitterProcessor для публикации сообщений в Kafka. Есть ли способ обработать ошибку при вызове EmitterProcessor.onNext(message)?

Даже когда узел Kafka Broker & Zookeeper не работает, я не вижу никаких исключений во время вызова метода onNext.