向 Kafka 发送消息时，Camel 中的自定义标头丢失

Question

我有以下路线。奇怪的是，自定义标头值“myHeader”在 Kafka 的消费者端丢失了。

您能否让我知道这是什么原因以及如何解决这个问题。

from("file://inputFolder?delay=2s&noop=true")
.convertBodyTo(String.class)
.setHeader("myHeader", constant("MY_HEADER_VALUE"))
.to("kafka:test-topic?brokers=localhost:9092");

from("kafka:test-topic?brokers=localhost:9092")
.log("${body}")
.log("***** myHeader: ${header.myHeader}")

myHeader 的值是一个空字符串，尽管我将其设置为“”MY_HEADER_VALUE”。

我们使用 Apache Camel 2.20.2 和 Spring Boot 版本 1.5.10.RELEASE。

Answer 1

好的，您使用的旧Camel 版本不支持此功能。从 Camel 2.22 开始支持，请参阅票证：https://issues.apache.org/jira/browse/CAMEL-12503