Skip to content

create a toHeader SMT  #902

Closed
Closed
@valdar

Description

@valdar

That SMT should take fields from a configured record value (supporting struct + schema or map cases) and copy the value in a configure header like:

transforms=toHeader
transforms.toHeader.type=org.apache.camel.kafkaconnect.transforms.ToHeader
transforms.toHeaderader.fields=to.address,cc.addresses
transforms.toHeaderr.headers=CamelHeader.to,CamelHeader.cc

this can be used as a base for extracting fields https://github.com/apache/kafka/blob/trunk/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ExtractField.java

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions