How to pass header from Processor to Transformer - Kafka Connector - Kamelets

问题描述 投票:0回答:0

我正在处理器中设置一些自定义标头,

public class CustomProcessor implements Processor {
   @OverRide
   public void process(Exchange exchange) throws Exception {
     exchange.getMessage().setHeader("dummy", "dummy");
     exchange.getIn().setHeader("dummy", "dummy");
   }
}

我正在尝试在 Transformer 中获取标头值(从上面的步骤),

public class CamelToKafkaHeadersTransform<R extends ConnectRecord> implements
Transformation {
   @OverRide
   public R apply(R record) {
      for(Header header : record.headers()) {
         System.out.println(header.key(), header.value());
      }
}
}

除了自定义标头,我还可以打印其他骆驼标头值。请帮助我如何将值从处理器传递到变压器。

apache-camel apache-camel-k
© www.soinside.com 2019 - 2024. All rights reserved.