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.
