我有一个基于camel的应用程序（带有xml描述的路由的spring）。我希望它能够将输入消息路由到未知数量的kafka主题（基于文件名模式和主题名之间的可配置匹配），这样我就不能在xml文件中预先为每个模式创建生产者。理想情况下，我们可以在消息头中设置主题，比如分区id。。。有人有什么建议吗？
hfyxw5xn1#
最后这是可能的。我指的是Kafka消费品的错误来源。在最新的版本中，它的行为和我希望的完全一样。
topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class);
因此，为了动态选择主题，必须在消息中设置kafkaconstants.topic头。
1条答案
按热度按时间hfyxw5xn1#
最后这是可能的。我指的是Kafka消费品的错误来源。在最新的版本中，它的行为和我希望的完全一样。
因此，为了动态选择主题，必须在消息中设置kafkaconstants.topic头。