为什么 header 值没有插入到 Spring DSL 中 Apache Camel 的 `to` url 路由参数中？

Question

我们有一个路由将接受 kafka.KEY 并将其用作 mqtt url 参数以将数据发送到正确的主题。

<routes
    xmlns="http://camel.apache.org/schema/spring">
    <route id="KafkaToMQTT">
        <from uri="kafka://mqtt?brokers=localhost:9092"/>
        <to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?action=start"/>
        <log message="Headers ${header.kafka.KEY}"/>
        <to uri="mqtt:mqtt?host=tcp://localhost:1883&amp;publishTopicName=try${header.kafka.KEY}"/>
        <to uri="log://camel.proxy?groupInterval=3&amp;level=INFO"/>
        <to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?action=stop"/>      
    </route>
</routes>

在日志消息中，我正确地看到了 ${header.kafka.KEY}，而在 mqtt 中，我得到的主题是 try${header.kafka.KEY}

这是什么原因，如何让header在那里使用？

Answer 1

为了避免使用正确的元素而不是to，即toD。

toD 正确连接了 url，所以正确的路由 XML 是：

<routes
    xmlns="http://camel.apache.org/schema/spring">
    <route id="KafkaToMQTT">
        <from uri="kafka://mqtt?brokers=localhost:9092"/>
        <to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?action=start"/>
        <log message="Headers ${header.kafka.KEY}"/>
        <toD uri="mqtt:mqtt?host=tcp://localhost:1883&amp;publishTopicName=ESP_02/try${header.kafka.KEY}"/>
        <to uri="log://camel.proxy?groupInterval=3&amp;level=INFO"/>
        <to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?action=stop"/>      
    </route>
</routes>

为什么 header 值没有插入到 Spring DSL 中 Apache Camel 的 `to` url 路由参数中？

Why header value isn't inserted into Apache Camel's `to` url parameter of the route in Spring DSL?

java

apache-camel

mqtt

camel-spring-dsl