apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
  annotations:
    dataflow.argoproj.io/description: |-
      This example shows an example of having two nodes in a pipeline.

      While they read from Kafka, they are connected by a NATS Streaming subject.
    dataflow.argoproj.io/owner: argoproj-labs
  name: 101-two-node
spec:
  steps:
  - cat: {}
    name: a
    sinks:
    - stan:
        subject: a-b
    sources:
    - kafka:
        topic: input-topic
  - cat: {}
    name: b
    sinks:
    - kafka:
        topic: output-topic
    sources:
    - stan:
        subject: a-b