我有下面的路线。奇怪的是,自定义头值“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\u header\u value”。
我们使用ApacheCamel2.20.2和SpringBootVersion1.5.10.0版本。
1条答案
按热度按时间kpbwa7wx1#
好的,所以在您使用的这个旧的camel版本中不支持这个。从camel 2.22开始支持its,请参见票证:https://issues.apache.org/jira/browse/camel-12503