Merge KeyValue

The merge-key-value transform function merges the fields of KeyValue records where both the key and value are structured types of the same schema type. (Currently only AVRO is supported).
The step name is merge-key-value and the UserConfig is controlled here: {"steps": [{"type": "merge-key-value"}]}.

Example

Produce an AVRO message with the payload: {key={keyField: key}, value={valueField: value}}.

AVRO
Result

{key={keyField: key}, value={valueField: value}}

{key={keyField: key}, value={keyField: key, valueField: value}}

The function merges the KeyValue fields (because both are AVRO type) and outputs {key={keyField: key}, value={keyField: key, valueField: value}} to the output topic.

What’s next?

For more, see Transform Functions or the Pulsar documentation.