Apache Camel - Kafka 生产者：动态设置主题名称

Question

我有一个基于骆驼的应用程序（带有 XML 描述的路由的 spring）。我希望它能够将输入消息路由到未知数量的 kafka 主题（基于文件名模式和主题名之间的可配置匹配），因此我无法提前在 xml 文件中为每个模式创建生产者。

理想情况下，我们应该能够在消息头中设置主题，例如分区 id...

有人有建议吗？

Answer 1

终于有可能了。我指的是卡夫卡消费者的错误来源。在最新版本中，它的行为与我希望的完全一样。

topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class);

因此必须在消息中设置 KafkaCONstants.TOPIC 标头才能动态选择主题。