Transformer not printing the custom headers set in Processor

[amulrajesh]

Using kafka-connector and kamelets,

I am setting some custom header in Processor,

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

And I am trying to get the header value (from above step) in Transformer,

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

Except the custom header I am able to print other camel header values.

[squakez]

@amulrajesh I've moved the issue in the camel-kafka-connector project where I think you'll receive better support.

[oscerd]

It needs to be prefixed with CamelHeader.

As reported in the documentation and in the code:

camel-kafka-connector/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java

Line 48 in 07013f7

public static final String HEADER_CAMEL_PREFIX = "CamelHeader.";

essentially it needs to CamelHeader.dummy as header name.

[amulrajesh]

Thanks oscerd