apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: |-
      This example of Go 1.17 handler.

      [Learn about handlers](../docs/HANDLERS.md)
    dataflow.argoproj.io/owner: argoproj-labs
  name: 104-golang1-17
spec:
  steps:
  - code:
      runtime: golang1-17
      source: |-
        package main

        import "context"

        func Handler(ctx context.Context, m []byte) ([]byte, error) {
          return []byte("hi " + string(m)), nil
        }
    name: main
    sinks:
    - log: {}
    sources:
    - kafka:
        topic: input-topic