向kafka发送消息时,camel中的自定义头丢失

qkf9rpyu  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(767)

我有下面的路线。奇怪的是,自定义头值“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版本。

kpbwa7wx

kpbwa7wx1#

好的,所以在您使用的这个旧的camel版本中不支持这个。从camel 2.22开始支持its,请参见票证:https://issues.apache.org/jira/browse/camel-12503

相关问题