阿帕奇骆驼 - 卡夫卡生产者：动态设置主题名称

Question

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

理想的情况下，我们将能够设定的主题中的邮件标题，如分区ID ...

有没有人有什么建议？

Answer 1

最后这是可能的。我指的是卡夫卡消费者的错误来源。在最新的版本中，它的行为完全如我所愿。

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

所以人们必须在消息中设置KafkaCOnstants.TOPIC标题以便动态选择主题。