test: added kafka example

argoproj-labs · May 21, 2021 · 16362e4 · 16362e4
1 parent 786ae3d
commit 16362e4
Showing 1 changed file with 19 additions and 0 deletions.
diff --git a/examples/301-kafka-pipeline.yaml b/examples/301-kafka-pipeline.yaml
@@ -0,0 +1,19 @@
+apiVersion: dataflow.argoproj.io/v1alpha1
+kind: Pipeline
+metadata:
+  annotations:
+    dataflow.argoproj.io/description: |
+      This example shows reading and writing to cafe.
+    dataflow.argoproj.io/name: Kafka
+  creationTimestamp: null
+  name: kafka
+spec:
+  steps:
+  - cat: {}
+    name: main
+    sources:
+    - kafka:
+        topic: input-topic
+    sinks:
+    - kafka:
+        topic: output-topic