apache-camel - 如何在 Camel K Kafka URL 中使用 ${...}？

Question

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

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

不幸的是它说 Kafka URL 无效：</p>

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

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

有谁知道是什么导致了这个问题，我应该逃避美元符号还是花括号？

Answer 1

你需要使用发送动态所以替换为 toD

Answer 2

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