CamelSinkTask throws NPE on schemeless header

[jakubmalek]

CamelSinkTask is throwing NullPointerException during SinkRecord header mapping:

Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: null java.lang.NullPointerException at org.apache.camel.kafkaconnector.CamelSinkTask.mapHeader(CamelSinkTask.java:243) at org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:195) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:186) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:241) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829)

The error is thrown when SinkRecord header doesn't provide schema.