apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: |-
      This is an example of built-in mapping.

      Maps are written using expression syntax and must return a byte array.

      They have a single variable, `msg`, which is a byte array.

      [Learn about expressions](../docs/EXPRESSIONS.md)
    dataflow.argoproj.io/owner: argoproj-labs
  name: 102-map
spec:
  steps:
  - map:
      expression: |-
        bytes('hi ' + string(msg))
    name: main
    sinks:
    - kafka:
        topic: output-topic
    sources:
    - kafka:
        topic: input-topic