apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: |-
      This example is of the Java 16 handler.

      [Learn about handlers](../docs/HANDLERS.md)
    dataflow.argoproj.io/owner: argoproj-labs
  name: 104-java16
spec:
  steps:
  - code:
      runtime: java16
      source: |-
        import java.util.Map;

        public class Handler {
            public static byte[] Handle(byte[] msg, Map<String,String> context) throws Exception {
                return msg;
            }
        }
    name: main
    sinks:
    - kafka:
        topic: output-topic
    sources:
    - kafka:
        topic: input-topic