How to add header info in the Kafka Couchbase connector

HI,

I am using Kafka-Couchbase connector, the functionality is working fine, I am able to post messages to Kafka topic upon mutations/deletions on the couchbase documents. I would like to add headers to this event messages. Is there a way where I can add header info?

I tried to add header info to the DcpMutationMessage but getting below exception,

org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type STRING: class org.apache.kafka.common.header.internals.RecordHeader for field: “headers”
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:240)
at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
at com.couchbase.connect.kafka.filter.CustomFilter.pass(CustomFilter.java:53)
at com.couchbase.connect.kafka.CouchbaseSourceTask.poll(CouchbaseSourceTask.java:172)
at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:245)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:221)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

Please suggest.

Thanks,
Shivraj