如何在 Camel K Kafka URL 中使用 ${...}？答案

【问题标题】：How to use ${...} in Camel K Kafka URL?如何在 Camel K Kafka URL 中使用 ${...}？
【发布时间】：2021-12-04 00:06:42
【问题描述】：

我已将主题保存在标题中，并尝试在 Kafka URL 中访问它，如下所示：

from(...)
.process(...)
.to("kafka:${header.topic}?brokers=localhost:9092")

不幸的是它说 Kafka URL 无效：

org.apache.kafka.common.errors.InvalidTopicException: Invalid topics: [${header.topic}]

我已尝试将to(...) 替换为.log("${header.topic}") 并且可以在日志行中打印预期值。

有谁知道导致问题的原因，我应该避开美元符号还是花括号？

【问题讨论】：

【解决方案1】：

标头正文和属性值是动态值，每次流触发时可以采用不同的值。您必须将此指定给骆驼，而 toD 方法执行此操作。

【讨论】：

【解决方案2】：

您需要使用动态发送，因此将 to 替换为 toD

【讨论】：