来自另一条消费者路线的输入的骆驼消费者路线答案

【问题标题】：Camel consumer route with input from another consumer route来自另一条消费者路线的输入的骆驼消费者路线
【发布时间】：2022-12-13 18:35:17
【问题描述】：

我有一条 kafka 消费者路线，我从那里获取一些数据。

from("Kafka:foo?brokers=localhost:9092")

一旦我从消费者那里收到数据，就在 paho mqtt 消费者的主题名称中使用该数据。

from("paho:#?brokerUrl=tcp://localhost:1883")

我无法弄清楚如何从第一个消费者那里设置动态标头 CamelMqttTopic，因为两者似乎都是独立的流程。我在 Spring 框架中使用骆驼。如果我对骆驼的基本理解有缺陷，请原谅。

【问题讨论】：

标签： java apache-kafka apache-camel paho spring-camel

【解决方案1】：

您可以覆盖MQTT主题使用 CamelPahoOverrideTopic 消息头，值为卡夫卡通过 kafka.TOPIC 消息头访问的主题：

from("kafka:foo?brokers=localhost:9092")
    .setHeader(PahoConstants.CAMEL_PAHO_OVERRIDE_TOPIC, simple("${headers[kafka.TOPIC]"))
    .to("paho:#?brokerUrl=tcp://localhost:1883");

【讨论】：