我们有一个接受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&publishTopicName=try${header.kafka.KEY}"/>
<to uri="log://camel.proxy?groupInterval=3&level=INFO"/>
<to uri="micrometer:timer:camel.proxy.kafka.mqtt.stream?action=stop"/>
</route>
</routes>
在日志消息中,我正确地看到了${header.kafka.KEY},而在mqtt中,我得到的主题是try${header.kafka.KEY}
这是什么原因,如何使表头在那里使用?
1条答案
按热度按时间mgdq6dx11#
为了避免使用正确的元素而不是
to
,应该使用toD
。toD
正确连接了url,因此正确的路由XML为: