为什么在Spring DSL中,头值没有插入到Apache Camel的路由的'to' url参数中?

zrfyljdw  于 2022-11-07  发布在  Apache
关注(0)|答案(1)|浏览(188)

我们有一个接受kafka.KEY的路由,并使用它作为mqtturl参数将数据发送到正确的主题。

<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}
这是什么原因,如何使表头在那里使用?

mgdq6dx1

mgdq6dx11#

为了避免使用正确的元素而不是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>

相关问题