我正在处理器中设置一些自定义标头,
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());
}
}
}
除了自定义标头,我还可以打印其他骆驼标头值。请帮助我如何将值从处理器传递到变压器。