27.11. Kafka 헤더 전파

Kafka에서 메시지를 사용하면 헤더가 camel 교환 헤더로 자동으로 전파됩니다. 동일한 동작으로 지원되는 흐름 생성 - 특정 교환의 camel 헤더는 kafka 메시지 헤더로 전파됩니다.

kafka 헤더는 byte[] 값만 허용하므로 order camel exchange header는 해당 값을 bytes[] 로 직렬화해야 하며 그렇지 않으면 헤더를 건너뜁니다. 다음 헤더 값 유형이 지원됩니다. 문자열,Integer,Long,double,Boolean,byte[]. 참고: kafka 에서 camel exchange 로 전파되는 모든 헤더에는 기본적으로 byte[] 값이 포함됩니다. 기본 기능 uri 매개변수를 설정하려면 route 및 headerSerializer 에서 route에 대한 headerDeserializer 를 설정할 수 있습니다. 예제:

from("kafka:my_topic?headerDeserializer=#myDeserializer")
...
.to("kafka:my_topic?headerSerializer=#mySerializer")

from("kafka:my_topic?headerDeserializer=#myDeserializer")
...
.to("kafka:my_topic?headerSerializer=#mySerializer")

기본적으로 모든 헤더는 KafkaHeaderFilterStrategy 에 의해 필터링됩니다. 전략은 Camel 또는 org.apache.camel 접두사로 시작하는 헤더를 필터링합니다. 기본 전략은 경로 간 headerFilterStrategy uri 매개변수를 사용하여 재정의 할 수 있습니다.

from("kafka:my_topic?headerFilterStrategy=#myStrategy")
...
.to("kafka:my_topic?headerFilterStrategy=#myStrategy")

from("kafka:my_topic?headerFilterStrategy=#myStrategy")
...
.to("kafka:my_topic?headerFilterStrategy=#myStrategy")

myStrategy 오브젝트는 HeaderFilterStrategy 의 하위 클래스여야 하며 Camel 레지스트리(Maining/Blueprint)에서 Camel 레지스트리를 사용하여 CamelContext 에 배치해야 합니다.