kafka-connect-transform-common icon indicating copy to clipboard operation
kafka-connect-transform-common copied to clipboard

Published 20 hours ago • verified publisher icon jcustenborder

HeaderToField$Key STRING is not a supported type

Open arnitolog opened this issue 2 years ago • 0 comments

Hello,

I'm trying to copy the Header value to the key with the transformation below.

    transforms: "CreateDocID"
    transforms.CreateDocID.type: "com.github.jcustenborder.kafka.connect.transform.common.HeaderToField$Key"
    transforms.CreateDocID.header.mappings: "DocId:STRING"

according to the documentation It should work, but I get an error: Caused by: java.lang.UnsupportedOperationException: STRING is not a supported type.

Is it possible to use this transformation to change the key with value from the header?

arnitolog avatar May 12 '23 19:05 arnitolog