From 6c95c2b7c8904c0debfd31eca63a94c986eaacfe Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Tue, 1 Feb 2022 22:30:42 +0100
Subject: [PATCH] Add smoketests for UC4
---
theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh | 9 +++++++++
theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh | 9 +++++++++
theodolite-benchmarks/docker-test/uc4-flink/test.sh | 9 +++++++++
theodolite-benchmarks/docker-test/uc4-kstreams/test.sh | 9 +++++++++
4 files changed, 36 insertions(+)
create mode 100755 theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh
create mode 100755 theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh
create mode 100755 theodolite-benchmarks/docker-test/uc4-flink/test.sh
create mode 100755 theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
diff --git a/theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh b/theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh
new file mode 100755
index 000000000..f6a7eccb7
--- /dev/null
+++ b/theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh
@@ -0,0 +1,9 @@
+#!/bin/sh
+
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 2000 |
+ tee /dev/stderr |
+ awk -F ':' '!/^%/ {print $1}' |
+ sort |
+ uniq |
+ wc -l |
+ grep "\b21\b"
diff --git a/theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh b/theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh
new file mode 100755
index 000000000..f6a7eccb7
--- /dev/null
+++ b/theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh
@@ -0,0 +1,9 @@
+#!/bin/sh
+
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 2000 |
+ tee /dev/stderr |
+ awk -F ':' '!/^%/ {print $1}' |
+ sort |
+ uniq |
+ wc -l |
+ grep "\b21\b"
diff --git a/theodolite-benchmarks/docker-test/uc4-flink/test.sh b/theodolite-benchmarks/docker-test/uc4-flink/test.sh
new file mode 100755
index 000000000..71fd0fbeb
--- /dev/null
+++ b/theodolite-benchmarks/docker-test/uc4-flink/test.sh
@@ -0,0 +1,9 @@
+#!/bin/sh
+
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 500 |
+ tee /dev/stderr |
+ awk -F ':' '!/^%/ {print $1}' |
+ sort |
+ uniq |
+ wc -l |
+ grep "\b21\b"
diff --git a/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh b/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
new file mode 100755
index 000000000..75f020a63
--- /dev/null
+++ b/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
@@ -0,0 +1,9 @@
+#!/bin/sh
+
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 32 |
+ tee /dev/stderr |
+ awk -F ':' '!/^%/ {print $1}' |
+ sort |
+ uniq |
+ wc -l |
+ grep "\b16\b"
--
GitLab