我正在将kafka配置为routebuilder中的源代码。我的目标是处理Kafka断线的问题。我的routebuilder如下所示：

new RouteBuilder() {
        public void configure() {
            onException(Exception.class).process(exchange -> {
                final Exception exception = exchange.getException();
                logger.error(exception.getMessage());
                // will do more processing here
            });
            from(String.format("kafka:%s?brokers=%s:%s", topicName, host, port)).bean(getMyService(), "myMethod")
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    // some more processing
                }
            });
        }
    };

我提供了错误的主机和端口，希望看到异常。但是，在日志中没有看到异常，并且不会调用onexception处理。知道我做错了什么吗？
类似的问题可以通过运行https://github.com/apache/camel/blob/master/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/messageconsumerclient.java 本地没有任何kafka服务器运行。这样做会导致持续不断的消息流：

Connection to node -1 could not be established. Broker may not be available.

是否有方法引发异常？任何帮助都将不胜感激。