У меня есть следующий маршрут.Странно, что пользовательское значение заголовка «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.