阿帕奇骆驼 - 卡夫卡生产者:动态设置主题名称
问题描述:
我有一个骆驼基地应用程序(春季与XML中描述的路线)。我希望它能够将输入消息路由到未知数量的kafka主题(基于文件名模式和主题名称之间的可配置匹配),因此我无法事先在xml文件中为每个模式创建生产者。阿帕奇骆驼 - 卡夫卡生产者:动态设置主题名称
理想的情况下,我们将能够设定的主题中的邮件标题,如分区ID ...
有没有人有什么建议?
答
最后这是可能的。我指的是卡夫卡消费者的错误来源。在最新的版本中,它的行为完全如我所愿。
topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class);
所以人们必须在消息中设置KafkaCOnstants.TOPIC标题以便动态选择主题。